Skip to content

Commit

Permalink
airflow-14563- docs added
Browse files Browse the repository at this point in the history
  • Loading branch information
pateash committed Jul 7, 2022
1 parent e5fbc06 commit 1425c95
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions tests/sensors/test_external_task_sensor.py
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ def test_raise_with_external_task_sensor_task_group_and_task_id(self):
)
assert (
str(ctx.value) == "Values for `external_task_group_id` and `external_task_id` or "
"`external_task_ids` can't be set at the same time"
"`external_task_ids` can't be set at the same time"
)

# by default i.e. check_existence=False, if task_group doesn't exist, the sensor will run till timeout,
Expand Down Expand Up @@ -158,8 +158,10 @@ def test_external_task_group_sensor_failed_states(self):
failed_states=[State.FAILED],
dag=self.dag,
)
with pytest.raises(AirflowException, match=f"The external task_group '{TEST_TASK_GROUP_ID}' in DAG "
f"'{TEST_DAG_ID}' failed."):
with pytest.raises(
AirflowException,
match=f"The external task_group '{TEST_TASK_GROUP_ID}' in DAG '{TEST_DAG_ID}' failed.",
):
op.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, ignore_ti_state=True)

def test_catch_overlap_allowed_failed_state(self):
Expand Down

0 comments on commit 1425c95

Please sign in to comment.