This commit is contained in:
Maxime Beauchemin 2015-06-19 09:40:17 -07:00
Родитель 8a78712fac
Коммит 07e0e106d5
1 изменённых файлов: 1 добавлений и 1 удалений

Просмотреть файл

@ -123,7 +123,7 @@ class ExternalTaskSensor(BaseSensorOperator):
TI = TaskInstance
session = settings.Session()
import dateutil.parser
dttm = dateutil.parser.parse(dttm)
self.execution_date = dateutil.parser.parse(self.execution_date)
count = session.query(TI).filter(
TI.dag_id == self.external_dag_id,
TI.task_id == self.external_task_id,