The cloud-native orchestrator for the whole development lifecycle, with integrated lineage and observability.

dagster

I've got sqlalchemy autoflush enabled in the db model code that my solids run, and sometimes a pipeline run fails due to an integrity constraint failure that happened in a totally different pipeline. Seems the same celery worker executed both pipelines and reused the db session between the runs without first cleaning up after the first one caused an exception. This problem with celery+sqlalchemy is discussed here <http://www.prschmid.com/2013/04/using-sqlalchemy-with-celery-tasks.html>, and before adopting dagster we were extending celery.Task and calling `session.remove()` in its after_return method, just like that article recommends. What's the cleanest way to do this in dagster?

<@UH3RM70A2> do we have a way to add exit behavior to resources? Basically use them like a context manager

<@U013NCSN75K> you could take a look at <https://docs.dagster.io/_apidocs/modes-resources#dagster.resource>. You can use the context manager patter with
```try:
  yield &lt;session&gt;
finally:
  &lt;spin down&gt;```

Thanks <@U015C9U9RLK>! Would you have an example/code of wrapping a db session in a resource like this anywhere?

nm, found it <https://docs.dagster.io/0.8.10/overview/modes-resources-presets/modes-resources>