amoghrajesh commented on code in PR #53809:
URL: https://github.com/apache/airflow/pull/53809#discussion_r2236873927
##########
airflow-core/src/airflow/api_fastapi/execution_api/routes/xcoms.py:
##########
@@ -230,6 +230,7 @@ class GetXComSliceFilterParams(BaseModel):
start: int | None = None
stop: int | None = None
step: int | None = None
+ include_prior_dates: bool = False
Review Comment:
Yeah, better safe than sorry.
Added in
https://github.com/apache/airflow/pull/53809/commits/8889918515a63462f73db7142e830ee9f4bcca68
##########
task-sdk/tests/task_sdk/execution_time/test_task_runner.py:
##########
@@ -2066,8 +2066,7 @@ def test_xcom_pull_from_custom_xcom_backend(
class CustomOperator(BaseOperator):
def execute(self, context):
- value = context["ti"].xcom_pull(task_ids="pull_task",
key="key")
- print(f"Pulled XCom Value: {value}")
+ _ = context["ti"].xcom_pull(task_ids="pull_task", key="key")
Review Comment:
Handled.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
