You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "sam sen (JIRA)" <ji...@apache.org> on 2017/05/17 14:07:04 UTC
[jira] [Updated] (AIRFLOW-1220) Can't clear airflow jobs when using
schedule_interval of None
[ https://issues.apache.org/jira/browse/AIRFLOW-1220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
sam sen updated AIRFLOW-1220:
-----------------------------
Description:
My dag is set to use `schedule_interval=None`. I'm attempting to clear jobs so I can re-run failed jobs but I'm encountering the following errors.
<code>
[2017-05-17 14:02:14,718] {models.py:3834} WARNING - Could not update dag stats for s3_dag_test
[2017-05-17 14:02:14,718] {models.py:3835} ERROR - can't compare datetime.datetime to NoneType
Traceback (most recent call last):
File "/usr/lib/python2.7/site-packages/airflow/models.py", line 3831, in set_dirty
session.commit()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 874, in commit
self.transaction.commit()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 461, in commit
self._prepare_impl()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 441, in _prepare_impl
self.session.flush()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2139, in flush
self._flush(objects)
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2259, in _flush
transaction.rollback(_capture_exception=True)
File "/usr/lib64/python2.7/site-packages/sqlalchemy/util/langhelpers.py", line 66, in __exit__
compat.reraise(exc_type, exc_value, exc_tb)
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2223, in _flush
flush_context.execute()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.py", line 389, in execute
rec.execute(self)
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.py", line 577, in execute
uow
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 243, in delete_obj
uowtransaction))
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 357, in _organize_states_for_delete
states):
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 1108, in _connections_for_states
for state in _sort_states(states):
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 1130, in _sort_states
sorted(persistent, key=lambda q: q.key[1])
TypeError: can't compare datetime.datetime to NoneType
</code>
was:
My dag is set to use `schedule_interval=None`. I'm attempting to clear jobs so I can re-run failed jobs but I'm encountering the following errors.
```[2017-05-17 14:02:14,718] {models.py:3834} WARNING - Could not update dag stats for s3_dag_test
[2017-05-17 14:02:14,718] {models.py:3835} ERROR - can't compare datetime.datetime to NoneType
Traceback (most recent call last):
File "/usr/lib/python2.7/site-packages/airflow/models.py", line 3831, in set_dirty
session.commit()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 874, in commit
self.transaction.commit()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 461, in commit
self._prepare_impl()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 441, in _prepare_impl
self.session.flush()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2139, in flush
self._flush(objects)
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2259, in _flush
transaction.rollback(_capture_exception=True)
File "/usr/lib64/python2.7/site-packages/sqlalchemy/util/langhelpers.py", line 66, in __exit__
compat.reraise(exc_type, exc_value, exc_tb)
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2223, in _flush
flush_context.execute()
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.py", line 389, in execute
rec.execute(self)
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.py", line 577, in execute
uow
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 243, in delete_obj
uowtransaction))
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 357, in _organize_states_for_delete
states):
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 1108, in _connections_for_states
for state in _sort_states(states):
File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 1130, in _sort_states
sorted(persistent, key=lambda q: q.key[1])
TypeError: can't compare datetime.datetime to NoneType
```
> Can't clear airflow jobs when using schedule_interval of None
> -------------------------------------------------------------
>
> Key: AIRFLOW-1220
> URL: https://issues.apache.org/jira/browse/AIRFLOW-1220
> Project: Apache Airflow
> Issue Type: Bug
> Reporter: sam sen
>
> My dag is set to use `schedule_interval=None`. I'm attempting to clear jobs so I can re-run failed jobs but I'm encountering the following errors.
> <code>
> [2017-05-17 14:02:14,718] {models.py:3834} WARNING - Could not update dag stats for s3_dag_test
> [2017-05-17 14:02:14,718] {models.py:3835} ERROR - can't compare datetime.datetime to NoneType
> Traceback (most recent call last):
> File "/usr/lib/python2.7/site-packages/airflow/models.py", line 3831, in set_dirty
> session.commit()
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 874, in commit
> self.transaction.commit()
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 461, in commit
> self._prepare_impl()
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 441, in _prepare_impl
> self.session.flush()
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2139, in flush
> self._flush(objects)
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2259, in _flush
> transaction.rollback(_capture_exception=True)
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/util/langhelpers.py", line 66, in __exit__
> compat.reraise(exc_type, exc_value, exc_tb)
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2223, in _flush
> flush_context.execute()
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.py", line 389, in execute
> rec.execute(self)
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.py", line 577, in execute
> uow
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 243, in delete_obj
> uowtransaction))
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 357, in _organize_states_for_delete
> states):
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 1108, in _connections_for_states
> for state in _sort_states(states):
> File "/usr/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 1130, in _sort_states
> sorted(persistent, key=lambda q: q.key[1])
> TypeError: can't compare datetime.datetime to NoneType
> </code>
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)