Jobs draining after deployment of new workflow

**Problem**
For this moment we remove old DAGS from the composer bucket when we deploy a new DAGS. It can result in gaps in data because in this flow it is possible to remove workflow with an in-progress state.

**How to fix**
We should use some kind of draining mechanism that allows ending the in-progress workflows after the current interval is completed and then starts freshly deployed workflows and remove the old one.