Skip to content

Commit 5581f56

Browse files
committed
Fixup tests
1 parent 5101026 commit 5581f56

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

airflow-core/tests/unit/jobs/test_triggerer_job.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1228,6 +1228,7 @@ def get_type_names(union_type):
12281228
"ResendLoggingFD",
12291229
"CreateHITLDetailPayload",
12301230
"SetRenderedMapIndex",
1231+
"GetDagState",
12311232
}
12321233

12331234
in_task_but_not_in_trigger_runner = {
@@ -1247,6 +1248,7 @@ def get_type_names(union_type):
12471248
"PreviousDagRunResult",
12481249
"PreviousTIResult",
12491250
"HITLDetailRequestResult",
1251+
"DagStateResult",
12501252
}
12511253

12521254
supervisor_diff = (

task-sdk/tests/task_sdk/execution_time/test_supervisor.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1422,7 +1422,8 @@ class RequestTestCase:
14221422
client_mock=ClientMock(
14231423
method_path="connections.get",
14241424
args=("test_conn",),
1425-
response=ConnectionResult(conn_id="test_conn", conn_type="mysql", schema="mysql"), # type: ignore[call-arg]
1425+
response=ConnectionResult(conn_id="test_conn", conn_type="mysql", schema="mysql"),
1426+
# type: ignore[call-arg]
14261427
),
14271428
expected_body={
14281429
"conn_id": "test_conn",
@@ -2459,10 +2460,12 @@ class RequestTestCase:
24592460
expected_body={"is_paused": False, "type": "DagStateResult"},
24602461
client_mock=ClientMock(
24612462
method_path="dags.get_state",
2462-
args=("test_dag",),
2463+
kwargs={
2464+
"dag_id": "test_dag",
2465+
},
24632466
response=DagStateResult(is_paused=False),
24642467
),
2465-
test_id="get_dag_run_state",
2468+
test_id="get_dag_state",
24662469
),
24672470
]
24682471

0 commit comments

Comments
 (0)