Merge pull request #923 from DalgoT4D/pass-the-cron-to-prefect

pass the cron to prefect

ddpui/management/commands/createedrsendreportdataflow.py

@@ -63,6 +63,7 @@ def create_dataflow(self, org: Org, org_task: OrgTask, cron: str):
                         "org_slug": org_task.org.slug,
                     }
                 },
+                cron=cron,
             ),
             MANUL_DBT_WORK_QUEUE,
         )

ddpui/tests/services/test_prefect_service.py

@@ -252,7 +252,10 @@ def test_create_airbyte_server_block(mock_post: Mock):
     assert response == ("the-block-id", "theblockname")
 
 
-def test_update_airbyte_server_block():
+@patch("ddpui.ddpprefect.prefect_service.prefect_put")
+def test_update_airbyte_server_block(mock_put: Mock):
+    """tests update_airbyte_server_block"""
+    mock_put.side_effect = Exception("not implemented")
     with pytest.raises(Exception) as excinfo:
         update_airbyte_server_block("blockname")
     assert str(excinfo.value) == "not implemented"