my prefect server setup
prefect-metrics.waow.tech
python
orchestration
fix weave cache key collision between merge and relationship tasks
ByTagsHash now includes task_key in the cache key so identify_tag_merges
and discover_tag_relationships don't share cached results.
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
+3
-2
+3
-2
flows/weave.py
+3
-2
flows/weave.py
···
62
62
63
63
64
64
class ByTagsHash(CachePolicy):
65
-
"""Cache by hash of all tags. Skip LLM if tag set unchanged."""
65
+
"""Cache by hash of all tags, scoped per task. Skip LLM if tag set unchanged."""
66
66
67
67
def compute_key(
68
68
self,
···
75
75
if not tags_text:
76
76
return None
77
77
h = hashlib.md5(tags_text.encode()).hexdigest()[:12]
78
-
return f"weave-tags/{h}"
78
+
task_key = task_ctx.task.task_key if task_ctx else "unknown"
79
+
return f"weave-{task_key}/{h}"
79
80
80
81
81
82
# ---------------------------------------------------------------------------