jaketf commented on a change in pull request #6210: [AIRFLOW-5567]
BaseAsyncOperator
URL: https://github.com/apache/airflow/pull/6210#discussion_r339146836
##
File path: airflow/models/base_reschedule_poke_operator.py
##
@@ -0,0 +1,218 @@
+# -*- coding: utf-8 -*-
+#
+# Lic
jaketf commented on a change in pull request #6210: [AIRFLOW-5567]
BaseAsyncOperator
URL: https://github.com/apache/airflow/pull/6210#discussion_r339141292
##
File path: airflow/gcp/hooks/dataproc.py
##
@@ -485,7 +490,8 @@ def submit(
project_id: str,
job
jaketf commented on a change in pull request #6210: [AIRFLOW-5567]
BaseAsyncOperator
URL: https://github.com/apache/airflow/pull/6210#discussion_r337223464
##
File path: airflow/models/base_async_operator.py
##
@@ -0,0 +1,161 @@
+# -*- coding: utf-8 -*-
+#
+# Licensed to t
jaketf commented on a change in pull request #6210: [AIRFLOW-5567]
BaseAsyncOperator
URL: https://github.com/apache/airflow/pull/6210#discussion_r336785732
##
File path: airflow/models/base_async_operator.py
##
@@ -0,0 +1,161 @@
+# -*- coding: utf-8 -*-
+#
+# Licensed to t
jaketf commented on a change in pull request #6210: [AIRFLOW-5567]
BaseAsyncOperator
URL: https://github.com/apache/airflow/pull/6210#discussion_r336286276
##
File path: tests/models/test_base_async_operator.py
##
@@ -0,0 +1,288 @@
+# -*- coding: utf-8 -*-
+#
+# Licensed t
jaketf commented on a change in pull request #6210: [AIRFLOW-5567]
BaseAsyncOperator
URL: https://github.com/apache/airflow/pull/6210#discussion_r336285919
##
File path: airflow/models/base_async_operator.py
##
@@ -0,0 +1,161 @@
+# -*- coding: utf-8 -*-
+#
+# Licensed to t
jaketf commented on a change in pull request #6210: [AIRFLOW-5567]
BaseAsyncOperator
URL: https://github.com/apache/airflow/pull/6210#discussion_r336285752
##
File path: airflow/models/base_async_operator.py
##
@@ -0,0 +1,161 @@
+# -*- coding: utf-8 -*-
+#
+# Licensed to t
