my prefect server setup
prefect-metrics.waow.tech
python
orchestration
temporarily revert cleanup naming to bisect crash
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
+1
-10
+1
-10
flows/cleanup.py
+1
-10
flows/cleanup.py
···
118
118
return {"deleted": deleted_total, "failed": failed_total}
119
119
120
120
121
-
def _cleanup_run_name():
122
-
import prefect.runtime
123
-
124
-
config = prefect.runtime.flow_run.parameters.get("config", {})
125
-
mode = "dry-run" if config.get("dry_run", True) else "live"
126
-
days = config.get("days_to_keep", 30)
127
-
return f"{mode}-{days}d"
128
-
129
-
130
-
@flow(name="cleanup", flow_run_name=_cleanup_run_name, log_prints=True)
121
+
@flow(name="cleanup", log_prints=True)
131
122
async def cleanup(config: RetentionConfig = RetentionConfig()) -> dict:
132
123
"""Delete old terminal flow runs.
133
124