You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2019/10/30 17:35:23 UTC
[GitHub] [airflow] yegeniy commented on issue #6281: Run batches of
(self-terminating) EMR JobFlows [AIRFLOW-5763]
yegeniy commented on issue #6281: Run batches of (self-terminating) EMR JobFlows [AIRFLOW-5763]
URL: https://github.com/apache/airflow/pull/6281#issuecomment-548026133
> couldn't this be implemented as multiple EmrCreateJobFlowOperators and
some sensors at the end
Yes, one of the use-cases I described could be replaced with existing EMR
operators and sensors. I probably shouldn’t have emphasized this use-case
as it’s not the main/novel use case.
The novel use-case is that this operator allows for dynamic behavior at
DagRun time without overwriting the DAG definition itself (that is, we get
to keep the history in the UI and have parallel runs each with different
definitions).
I agree that this isn’t a common use case for Airflow, but internally I’ve
found it to be a handy way to quickly iterate, develop, and run AWS
EMR-based workflows that require multiple clusters to execute in sequence.
Please feel free to close out this PR if it doesn’t belong in
`apache/airflow`. I can just leave the code up on my branch if someone
finds it useful in the future.
On Wed, Oct 30, 2019 at 8:09 AM Ash Berlin-Taylor <no...@github.com>
wrote:
> I'm not sure this operator is really useful enough to belong in Airflow
> core. If I'm reading the comments/docs correctly couldn't this be
> implemented as multiple EmrCreateJobFlowOperators and some sensors at the
> end?
>
> Right now I don't feel this needs a whole new operator to support it.
>
> —
> You are receiving this because you were mentioned.
> Reply to this email directly, view it on GitHub
> <https://github.com/apache/airflow/pull/6281?email_source=notifications&email_token=AACHPQUVAKYUETQ45EHKTOTQRF2NZA5CNFSM4I6MYH4KYY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGOECT5OUA#issuecomment-547870544>,
> or unsubscribe
> <https://github.com/notifications/unsubscribe-auth/AACHPQW7DPGYNPW2T4WAFM3QRF2NZANCNFSM4I6MYH4A>
> .
>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services