[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-27 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1243467709 ## airflow/providers/amazon/aws/operators/emr.py: ## @@ -556,27 +560,57 @@ def execute(self, context: Context) -> str | None:

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-27 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1243390208 ## airflow/providers/amazon/aws/triggers/emr.py: ## @@ -317,3 +317,72 @@ async def run(self) -> AsyncIterator[TriggerEvent]: await

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-27 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1243389518 ## airflow/providers/amazon/aws/waiters/emr.json: ## @@ -94,6 +94,37 @@ "state": "failure" } ] +}, +

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-27 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1243388995 ## docs/apache-airflow-providers-amazon/operators/emr/emr.rst: ## @@ -189,6 +189,11 @@ Wait on an Amazon EMR job flow state To monitor the state of an EMR job

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-23 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1240051624 ## airflow/providers/amazon/aws/sensors/emr.py: ## @@ -424,12 +431,16 @@ def __init__( job_flow_id: str, target_states: Iterable[str] | None =

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-23 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1239642693 ## airflow/providers/amazon/aws/sensors/emr.py: ## @@ -424,12 +431,16 @@ def __init__( job_flow_id: str, target_states: Iterable[str] | None =

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-23 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1239641163 ## airflow/providers/amazon/aws/triggers/emr.py: ## @@ -317,3 +317,72 @@ async def run(self) -> AsyncIterator[TriggerEvent]: await

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-21 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1236487758 ## airflow/providers/amazon/aws/triggers/emr.py: ## @@ -317,3 +317,75 @@ async def run(self) -> AsyncIterator[TriggerEvent]: await

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-21 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1236451048 ## airflow/providers/amazon/aws/operators/emr.py: ## @@ -555,6 +559,22 @@ def execute(self, context: Context) -> str | None:

[GitHub] [airflow] pankajastro commented on a diff in pull request #32029: Add deferrable mode in EMR operator and sensor

2023-06-20 Thread via GitHub
pankajastro commented on code in PR #32029: URL: https://github.com/apache/airflow/pull/32029#discussion_r1235285972 ## airflow/providers/amazon/aws/operators/emr.py: ## @@ -507,6 +509,7 @@ def __init__( max_tries: int | None = None, tags: dict | None = None,