code: def test_poke_not_completed(self, mocked_get_task_status, status):
      mocked_get_task_status.return_value = status
      assert not DmsTaskCompletedSensor(**self.default_op_kwargs).poke(
          {}
      )
  
file_path: airflow/tests/providers/amazon/aws/sensors/test_dms.py
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from airflow.exceptions import AirflowException, AirflowSkipException
  from airflow.providers.amazon.aws.hooks.dms import DmsHook
  from airflow.providers.amazon.aws.sensors.dms import DmsTaskCompletedSensor
label_desc: Use image node_id 4 for calling the TestDmsTaskCompletedSensor obj's underlying member method code with example usage: obj.test_poke_not_completed(mocked_get_task_status, status) without return types