Ash Berlin-Taylor
Ash Berlin-Taylor
What is the behaviour if the topic you try to create already exists? I'm assuming the underlying hook would fail with an exception, but I think the operator should catch...
> Would it be misleading for a task to succeed if the operation is should perform does not occur and the user didn't explicitly choose to be indifferent about the...
I think lets slim this down for now, and only add the methods/"entrypoints" that the scheduler needs, and then a custom class can user `super()` etc to do what it...
There is now `airflow/datasets/` folder -- so should we move this it to `airflow/datasets/manager.py`?
> > > Is this expected? Yes. Previously it showed `_PythonDecoratorOperator` or some such, which was.... ick.
Only providers test is failing/stalling. Unrelated to this change. Merging.
I'd be surprised if doing it ourselves is any quicker than letting postgres handle it itself. Could this be a case of missing indexes or the foreign side (i.e. on...
This works for the current example sub-dags we have in the tests -- is there any other case I should test?
We could extend the auto-register -- but that makes it slightly more complex for SubDag (we'd have to "unregister" a dag when it gets turned in to a sub dag)...
I still need to update the docs/tutorial etc to reflect this.