prefect

scripts/prefect/create_pause_deployment.py

@@ -0,0 +1,11 @@
+from prefect import flow
+
+if __name__ == "__main__":
+    flow.from_source(
+        source="https://github.com/AccelerationConsortium/ac-training-lab.git",
+        entrypoint="scripts/prefect/my_gh_pause_workflow.py:repo_info",
+    ).deploy(
+        name="pause-workflow-deployment",
+        work_pool_name="my-managed-pool",
+        cron="0 1 * * *",
+    )

scripts/prefect/my_gh_pause_workflow.py

@@ -0,0 +1,10 @@
+from prefect import flow, get_run_logger, pause_flow_run
+
+
+@flow
+def greet_user():
+    logger = get_run_logger()
+
+    user = pause_flow_run(wait_for_input=str)
+
+    logger.info(f"Hello, {user}!")