VBhojawala commented on issue #11858:
URL: https://github.com/apache/airflow/issues/11858#issuecomment-720993928
I am able to reproduce and i checked the query and database entries and
found following :
Query executed in order to fetch rows
SELECT xcom.key AS xcom_value
FROM xcom
WHERE xcom.task_id IN ('push', 'push_by_returning') AND xcom.dag_id =
'example_xcom' AND xcom.execution_date = '2020-11-01 00:00:00.000000'
ORDER BY xcom.execution_date DESC, xcom.timestamp DESC;
As shown in database entries in above table For execution Date 2020-11-01
and 2020-11-03 timestamps assigned to 'return_value' and 'value from pusher
1' are in different order.
Because of 'xcom.timestamp DESC;' in the query task with execution date
'2020-11-03' is returning values in different order and gets failed.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
