sweep_artifacts: narrow the optional flow store for mypy

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01WgBfkm4rCmtd1T4vHWjEPx
This commit is contained in:
2026-10-15 09:55:41 +02:00
co-authored by Claude Opus 5.5
parent f57b6f695b
commit b4ae333b6a
+9 -8
View File
@@ -403,14 +403,15 @@ def sweep_artifacts(
return 0
keep = set(session.exec(select(col(RunArtifact.digest)).distinct()).all())
for name in flows.list_flows() if flows else ():
for draft in (False, True):
try:
flow = flows.read_flow(name, draft=draft)
except FlowNotFound:
continue
for declared in flow.inputs:
_references_in(declared.initial, keep)
if flows is not None:
for name in flows.list_flows():
for draft in (False, True):
try:
flow = flows.read_flow(name, draft=draft)
except FlowNotFound:
continue
for declared in flow.inputs:
_references_in(declared.initial, keep)
keys = state.keys()
for start in range(0, len(keys), _SWEEP_BATCH):