Adam Boscarino
Adam Boscarino
This sounds like a great idea to me. 👍
I haven't tried to use SubDags with`dag-factory` yet, but I don't see why it couldn't be extended to handle them if it doesn't work now. I'll see if I can...
@brucemen711 That sounds reasonable to me. Want to submit a PR with the change?
That looks like it is importing fine and is just raising a warning.
This looks like a great idea! I'm not sure I'll get to it for a bit though, but feel free to submit a PR!
Not sure if anyone has done that yet, but they'd need to be set as the `ops_args` https://github.com/apache/airflow/blob/1.10.10/airflow/operators/python_operator.py#L81
I'm not sure where `payload` is coming in your example, but you could get the DAG name to your task using Jinja templates like this: ``` task_3: operator: airflow.operators.python_operator.PythonOperator python_callable_name:...
@andialbrecht - Is there anything else this PR needs to be merged? We'd like to use `sqlparse` for [Snowflake](https://www.snowflake.com) and this would be really helpful for adding the additional dialect...
This is impacting only one of our DAGs (we're on version 2.3.4), but it isn't clear why it is happening.
@matveykortsev I reopened the PR, but looks like there are some conflicts. I can take a look at getting them resolved in the next few days unless you beat me...