Skip to content

Commit ff8bad8

Browse files
committed
Fixup tests
1 parent 1691bc8 commit ff8bad8

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

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

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,7 @@
6969
ConnectionResult,
7070
CreateHITLDetailPayload,
7171
DagRunStateResult,
72+
DagStateResult,
7273
DeferTask,
7374
DeleteVariable,
7475
DeleteXCom,
@@ -80,6 +81,7 @@
8081
GetAssetEventByAssetAlias,
8182
GetConnection,
8283
GetDagRunState,
84+
GetDagState,
8385
GetDRCount,
8486
GetHITLDetailResponse,
8587
GetPreviousDagRun,
@@ -2288,6 +2290,16 @@ class RequestTestCase:
22882290
),
22892291
test_id="skip_downstream_tasks",
22902292
),
2293+
RequestTestCase(
2294+
message=GetDagState(dag_id="test_dag"),
2295+
expected_body={"is_paused": False, "type": "DagStateResult"},
2296+
client_mock=ClientMock(
2297+
method_path="dags.get_state",
2298+
args=("test_dag",),
2299+
response=DagStateResult(is_paused=False),
2300+
),
2301+
test_id="get_dag_run_state",
2302+
),
22912303
]
22922304

22932305

0 commit comments

Comments
 (0)