flow for testing retries

prefect.yaml

@@ -51,3 +51,16 @@ deployments:
       work_queue_name: default
       job_variables:
         image: "{{ build-image.image }}"
+
+  - name: retry-test
+    version:
+    tags: []
+    description:
+    schedule:
+    entrypoint: retry_flow.py:testing_retries
+    parameters: {}
+    work_pool:
+      name: cloud-run-v2-pool
+      work_queue_name: default
+      job_variables:
+        image: "{{ build-image.image }}"

retry_flow.py

@@ -0,0 +1,21 @@
+from prefect import flow, task
+
+
+@flow
+def testing_retries():
+    successful_task()
+    failing_task()
+
+
+@task
+def successful_task():
+    print("good")
+
+
+@task
+def failing_task():
+    raise Exception("bad")
+
+
+if __name__ == "__main__":
+    testing_retries()