AngeloPingoGalp commented on issue #27785: URL: https://github.com/apache/airflow/issues/27785#issuecomment-1320842492
Hi Niko, Yes, we tested with the manual trigger. I've tested your code and the "read_xcom_value" task didn't read the xcom value. Did you test it? `*** Log file does not exist: /opt/airflow/logs/dag_id=test_xcom_issue/run_id=scheduled__2022-11-19T00:00:00+00:00/task_id=read_xcom_value/attempt=1.log *** Fetching from: http://airflow-2-4-3-worker-0.airflow-2-4-3-worker.airflow.svc.cluster.local:8793/log/dag_id=test_xcom_issue/run_id=scheduled__2022-11-19T00:00:00+00:00/task_id=read_xcom_value/attempt=1.log [2022-11-19, 09:02:33 UTC] {taskinstance.py:1165} INFO - Dependencies all met for <TaskInstance: test_xcom_issue.read_xcom_value scheduled__2022-11-19T00:00:00+00:00 [queued]> [2022-11-19, 09:02:33 UTC] {taskinstance.py:1165} INFO - Dependencies all met for <TaskInstance: test_xcom_issue.read_xcom_value scheduled__2022-11-19T00:00:00+00:00 [queued]> [2022-11-19, 09:02:33 UTC] {taskinstance.py:1362} INFO - -------------------------------------------------------------------------------- [2022-11-19, 09:02:33 UTC] {taskinstance.py:1363} INFO - Starting attempt 1 of 1 [2022-11-19, 09:02:33 UTC] {taskinstance.py:1364} INFO - -------------------------------------------------------------------------------- [2022-11-19, 09:02:33 UTC] {taskinstance.py:1383} INFO - Executing <Task(PythonOperator): read_xcom_value> on 2022-11-19 00:00:00+00:00 [2022-11-19, 09:02:33 UTC] {standard_task_runner.py:55} INFO - Started process 25913 to run task [2022-11-19, 09:02:33 UTC] {standard_task_runner.py:82} INFO - Running: ['airflow', 'tasks', 'run', 'test_xcom_issue', 'read_xcom_value', 'scheduled__2022-11-19T00:00:00+00:00', '--job-id', '460', '--raw', '--subdir', 'DAGS_FOLDER/tests/issue_response.py', '--cfg-path', '/tmp/tmppzc4h1pm'] [2022-11-19, 09:02:33 UTC] {standard_task_runner.py:83} INFO - Job 460: Subtask read_xcom_value [2022-11-19, 09:02:33 UTC] {task_command.py:376} INFO - Running <TaskInstance: test_xcom_issue.read_xcom_value scheduled__2022-11-19T00:00:00+00:00 [running]> on host airflow-2-4-3-worker-0.airflow-2-4-3-worker.airflow.svc.cluster.local [2022-11-19, 09:02:33 UTC] {taskinstance.py:1590} INFO - Exporting the following env vars: AIRFLOW_CTX_DAG_OWNER=airflow AIRFLOW_CTX_DAG_ID=test_xcom_issue AIRFLOW_CTX_TASK_ID=read_xcom_value AIRFLOW_CTX_EXECUTION_DATE=2022-11-19T00:00:00+00:00 AIRFLOW_CTX_TRY_NUMBER=1 AIRFLOW_CTX_DAG_RUN_ID=scheduled__2022-11-19T00:00:00+00:00 [2022-11-19, 09:02:33 UTC] {logging_mixin.py:137} INFO - I got this from xcom: None [2022-11-19, 09:02:33 UTC] {python.py:177} INFO - Done. Returned value was: None [2022-11-19, 09:02:33 UTC] {taskinstance.py:1401} INFO - Marking task as SUCCESS. dag_id=test_xcom_issue, task_id=read_xcom_value, execution_date=20221119T000000, start_date=20221119T090233, end_date=20221119T090233 [2022-11-19, 09:02:33 UTC] {local_task_job.py:159} INFO - Task exited with return code 0 [2022-11-19, 09:02:33 UTC] {taskinstance.py:2623} INFO - 0 downstream tasks scheduled from follow-on schedule check` -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
