Skip to content

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
Co-authored-by: Kaxil Naik <[email protected]>
  • Loading branch information
amoghrajesh and kaxil authored Jan 9, 2025
1 parent d9f315a commit b589847
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions task_sdk/tests/execution_time/test_task_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -559,7 +559,7 @@ def execute(self, context):
{"push_task1", "push_task2"},
],
)
def test_xcom_pull_behavior(mocked_parse, make_ti_context, mock_supervisor_comms, spy_agency, task_ids):
def test_xcom_pull_behavior(create_runtime_ti, mock_supervisor_comms, spy_agency, task_ids):
"""Test that a task pulls the expected XCom value if it exists."""

class CustomOperator(BaseOperator):
Expand All @@ -573,7 +573,7 @@ def execute(self, context):
)

what = StartupDetails(ti=ti, file="", requests_fd=0, ti_context=make_ti_context())
runtime_ti = mocked_parse(what, ti.dag_id, task)
runtime_ti = create_runtime_ti(task=task)

mock_supervisor_comms.xcom_pull.return_value = "xcom_value"

Expand Down

0 comments on commit b589847

Please sign in to comment.