Folks,
I've some testes, which used to pass earlier, but recently they started
failing. When I looked closely it appeared that xcom_push is behaving
differently.
So this is is the current code, which throws the error mentioned below to it
DEFAULT_DATE = datetime(2017, 1, 1)
ti = TaskInstance(task=task, execution_date=DEFAULT_DATE)
ti.xcom_push('abcd', 12345)
File "build/bdist.macosx-10.11-intel/egg/sqlalchemy_utc.py", line
31, in process_bind_param
raise ValueError('naive datetime is disallowed')
StatementError: (exceptions.ValueError) naive datetime is disallowed
[SQL: u'DELETE FROM xcom WHERE xcom."key" = ? AND xcom.execution_date
= ? AND xcom.task_id = ? AND xcom.dag_id = ?'] [parameters: [{}]]
When I changed the execution date param to a string, it fails with other
error.
ti = TaskInstance(task=task, execution_date=DEFAULT_DATE.isoformat())
ti.xcom_push('abcd', 12345)
File "build/bdist.macosx-10.11-intel/egg/sqlalchemy_utc.py", line
29, in process_bind_param
repr(value))
StatementError: (exceptions.TypeError) expected datetime.datetime, not
'2017-01-01T00:00:00' [SQL: u'DELETE FROM xcom WHERE xcom."key" = ?
AND xcom.execution_date = ? AND xcom.task_id = ? AND xcom.dag_id = ?']
[parameters: [{}]]
Somehow I feel that it is linked with *sqlalchemy_utc* library, though
I may be wrong and its just missing some timezone related settings.
Please let me know if anyone else has faced this issue as well.
Thanks,
Sumit
