my prefect server setup
prefect-metrics.waow.tech
python
orchestration
fix: add createdAt/updatedAt to connection records, uppercase connectionType
semble requires these fields for indexing. without them, connections
exist in PDS but don't render in the UI.
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
+9
-2
+9
-2
flows/curate.py
+9
-2
flows/curate.py
···
373
373
connection_type: str,
374
374
note: str = "",
375
375
) -> str:
376
-
"""Create a connection between two entities (AT URIs or URLs). connection_type: related, supports, opposes, addresses, helpful, explainer, leads_to, supplements."""
377
-
record: dict[str, Any] = {"source": source, "target": target, "connectionType": connection_type}
376
+
"""Create a connection between two entities (AT URIs or URLs). connection_type: RELATED, SUPPORTS, OPPOSES, ADDRESSES, HELPFUL, EXPLAINER, LEADS_TO, SUPPLEMENTS."""
377
+
now = datetime.now(timezone.utc).isoformat()
378
+
record: dict[str, Any] = {
379
+
"source": source,
380
+
"target": target,
381
+
"connectionType": connection_type.upper(),
382
+
"createdAt": now,
383
+
"updatedAt": now,
384
+
}
378
385
if note:
379
386
record["note"] = note[:1000]
380
387
try: