Add Prefect orchestration

pipeline/.python-version

@@ -0,0 +1 @@
+3.12

pipeline/flow.py

@@ -0,0 +1,11 @@
+from prefect import flow, get_run_logger
+
+
+@flow
+def my_flow():
+    logger = get_run_logger()
+    logger.info("Hello from ECS!!")
+
+
+if __name__ == "__main__":
+    my_flow()

pipeline/hello.py

@@ -0,0 +1,16 @@
+from prefect import flow
+
+
+@flow(log_prints=True)
+def hello_world(name: str = "world", goodbye: bool = False):
+    print(f"Hello {name} from Prefect! 🤗")
+
+    if goodbye:
+        print(f"Goodbye {name}!")
+
+
+if __name__ == "__main__":
+    hello_world.serve(name="my-first-deployment",
+                      tags=["onboarding"],
+                      parameters={"goodbye": True},
+                      interval=60)

pipeline/pyproject.toml

@@ -0,0 +1,10 @@
+[project]
+name = "pipeline"
+version = "0.1.0"
+description = "Add your description here"
+readme = "README.md"
+requires-python = ">=3.12"
+dependencies = [
+    "prefect-aws>=0.5.0",
+    "prefect>=3.0.2",
+]