my prefect server setup
prefect-metrics.waow.tech
python
orchestration
add descriptive flow run names for parameterized flows
cleanup: shows dry-run/live mode and retention window (e.g. "dry-run-30d")
gh-notifications: shows "unread" or "all"
diagnostics: add explicit name="diagnostics" for consistency
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
+19
-3
+10
-1
flows/cleanup.py
+10
-1
flows/cleanup.py
···
118
118
return {"deleted": deleted_total, "failed": failed_total}
119
119
120
120
121
-
@flow(name="cleanup", log_prints=True)
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)
122
131
async def cleanup(config: RetentionConfig = RetentionConfig()) -> dict:
123
132
"""Delete old terminal flow runs.
124
133
+1
-1
flows/diagnostics.py
+1
-1
flows/diagnostics.py
+8
-1
flows/gh_notifications.py
+8
-1
flows/gh_notifications.py
···
159
159
return write_github_issues(items, db_path)
160
160
161
161
162
-
@flow(name="gh-notifications", log_prints=True)
162
+
def _gh_run_name():
163
+
import prefect.runtime
164
+
165
+
unread = prefect.runtime.flow_run.parameters.get("only_unread", True)
166
+
return "unread" if unread else "all"
167
+
168
+
169
+
@flow(name="gh-notifications", flow_run_name=_gh_run_name, log_prints=True)
163
170
def gh_notifications(only_unread: bool = True) -> list[IssueOrPR]:
164
171
"""
165
172
Fetch GitHub notifications and persist each issue/PR as a cached JSON result.