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:
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
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"
}
]
+},
+
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
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 =
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 =
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
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
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:
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,
10 matches
Mail list logo