seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r219044092
##
File path: airflow/models.py
##
@@ -1744,6 +1749,29 @@ def dry_run(self):
self.
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218587026
##
File path: airflow/models.py
##
@@ -1744,6 +1749,29 @@ def dry_run(self):
self.
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218567791
##
File path: airflow/sensors/base_sensor_operator.py
##
@@ -65,6 +89,11 @@ def poke(self,
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218564723
##
File path: airflow/models.py
##
@@ -56,8 +56,8 @@
from sqlalchemy import (
Colum
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218564370
##
File path: airflow/sensors/base_sensor_operator.py
##
@@ -75,11 +104,24 @@ def execute(s
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218564334
##
File path: airflow/ti_deps/deps/ready_to_reschedule.py
##
@@ -0,0 +1,62 @@
+# -*- coding
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218563478
##
File path: airflow/sensors/base_sensor_operator.py
##
@@ -75,11 +104,24 @@ def execute(s
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218308398
##
File path: airflow/models.py
##
@@ -1744,6 +1749,29 @@ def dry_run(self):
self.
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218308245
##
File path: airflow/models.py
##
@@ -1744,6 +1749,29 @@ def dry_run(self):
self.
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218307927
##
File path: airflow/models.py
##
@@ -56,8 +56,8 @@
from sqlalchemy import (
Colum
seelmann commented on a change in pull request #3596: [AIRFLOW-2747] Explicit
re-schedule of sensors
URL: https://github.com/apache/incubator-airflow/pull/3596#discussion_r218305157
##
File path: airflow/models.py
##
@@ -56,8 +56,8 @@
from sqlalchemy import (
Colum
11 matches
Mail list logo