fix import async fun
Browse files
__pycache__/DB_utils.cpython-310.pyc
CHANGED
|
Binary files a/__pycache__/DB_utils.cpython-310.pyc and b/__pycache__/DB_utils.cpython-310.pyc differ
|
|
|
__pycache__/maintenance_flow.cpython-310.pyc
CHANGED
|
Binary files a/__pycache__/maintenance_flow.cpython-310.pyc and b/__pycache__/maintenance_flow.cpython-310.pyc differ
|
|
|
__pycache__/prefect_utils.cpython-310.pyc
CHANGED
|
Binary files a/__pycache__/prefect_utils.cpython-310.pyc and b/__pycache__/prefect_utils.cpython-310.pyc differ
|
|
|
prefect_utils.py
CHANGED
|
@@ -14,7 +14,7 @@ def start_prefect_worker(work_pool_name: str = "ot2-pool"):
|
|
| 14 |
|
| 15 |
from prefect.client import get_client
|
| 16 |
|
| 17 |
-
async def
|
| 18 |
async with get_client() as client:
|
| 19 |
await client.create_flow_run_from_deployment(
|
| 20 |
name="request-wells-maintenance/wells-maintenance",
|
|
|
|
| 14 |
|
| 15 |
from prefect.client import get_client
|
| 16 |
|
| 17 |
+
async def trigger_maintenance_request(maintenance_type: str):
|
| 18 |
async with get_client() as client:
|
| 19 |
await client.create_flow_run_from_deployment(
|
| 20 |
name="request-wells-maintenance/wells-maintenance",
|