We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b4139d2 commit e4609d1Copy full SHA for e4609d1
services/director-v2/src/simcore_service_director_v2/modules/db/repositories/comp_pipelines.py
@@ -42,16 +42,12 @@ async def upsert_pipeline(
42
**pipeline_at_db.model_dump(mode="json", by_alias=True)
43
)
44
# FIXME: This is not a nice thing. this part of the information should be kept in comp_runs.
45
- update_exclusion_policy = set()
46
- if not dag_graph.nodes():
47
- update_exclusion_policy.add("dag_adjacency_list")
48
on_update_stmt = insert_stmt.on_conflict_do_update(
49
index_elements=[comp_pipeline.c.project_id],
50
set_=pipeline_at_db.model_dump(
51
mode="json",
52
by_alias=True,
53
exclude_unset=True,
54
- exclude=update_exclusion_policy,
55
),
56
57
async with self.db_engine.begin() as conn:
0 commit comments