Add supervisor handling test

Author: uranusjr

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

@@ -74,6 +74,7 @@
     GetTICount,
     GetVariable,
     GetXCom,
+    GetXComSequenceItem,
     OKResponse,
     PrevSuccessfulDagRunResult,
     PutVariable,
@@ -1436,6 +1437,36 @@ def watched_subprocess(self, mocker):
                 TaskStatesResult(task_states={"run_id": {"task1": "success", "task2": "failed"}}),
                 id="get_task_states",
             ),
+            pytest.param(
+                GetXComSequenceItem(
+                    key="test_key",
+                    dag_id="test_dag",
+                    run_id="test_run",
+                    task_id="test_task",
+                    offset=0,
+                ),
+                b'{"key":"test_key","value":"test_value","type":"XComResult"}\n',
+                "xcoms.get_sequence_item",
+                ("test_dag", "test_run", "test_task", "test_key", 0),
+                {},
+                XComResult(key="test_key", value="test_value"),
+                id="get_xcom_seq_item",
+            ),
+            pytest.param(
+                GetXComSequenceItem(
+                    key="test_key",
+                    dag_id="test_dag",
+                    run_id="test_run",
+                    task_id="test_task",
+                    offset=2,
+                ),
+                b'{"error":"XCOM_NOT_FOUND","detail":null,"type":"ErrorResponse"}\n',
+                "xcoms.get_sequence_item",
+                ("test_dag", "test_run", "test_task", "test_key", 2),
+                {},
+                ErrorResponse(error=ErrorType.XCOM_NOT_FOUND),
+                id="get_xcom_seq_item_not_found",
+            ),
         ],
     )
     def test_handle_requests(