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.