Skip to content

Commit 28dd6fd

Browse files
fix deprecated
1 parent bb10df1 commit 28dd6fd

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

services/director-v2/src/simcore_service_director_v2/modules/db/repositories/comp_pipelines.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ async def get_pipeline(self, project_id: ProjectID) -> CompPipelineAtDB:
2626
row: RowProxy | None = await result.fetchone()
2727
if not row:
2828
raise PipelineNotFoundError(str(project_id))
29-
return CompPipelineAtDB.from_orm(row)
29+
return CompPipelineAtDB.model_validate(row)
3030

3131
async def upsert_pipeline(
3232
self,

services/director-v2/src/simcore_service_director_v2/modules/db/repositories/comp_runs.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ async def get(
5151
row: RowProxy | None = await result.first()
5252
if not row:
5353
raise ComputationalRunNotFoundError
54-
return CompRunsAtDB.from_orm(row)
54+
return CompRunsAtDB.model_validate(row)
5555

5656
async def list(
5757
self, filter_by_state: set[RunningState] | None = None
@@ -70,7 +70,7 @@ async def list(
7070
)
7171
)
7272
):
73-
runs_in_db.append(CompRunsAtDB.from_orm(row))
73+
runs_in_db.append(CompRunsAtDB.model_validate(row))
7474
return list(runs_in_db)
7575

7676
async def create(
@@ -114,7 +114,7 @@ async def create(
114114
.returning(literal_column("*"))
115115
)
116116
row = await result.first()
117-
return CompRunsAtDB.from_orm(row)
117+
return CompRunsAtDB.model_validate(row)
118118
except ForeignKeyViolation as exc:
119119
raise ClusterNotFoundError(cluster_id=cluster_id) from exc
120120

@@ -133,7 +133,7 @@ async def update(
133133
.returning(literal_column("*"))
134134
)
135135
row = await result.first()
136-
return CompRunsAtDB.from_orm(row) if row else None
136+
return CompRunsAtDB.model_validate(row) if row else None
137137

138138
async def set_run_result(
139139
self,

services/director-v2/src/simcore_service_director_v2/modules/db/repositories/projects_networks.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ async def get_projects_networks(self, project_id: ProjectID) -> ProjectsNetworks
2323
).first()
2424
if not row:
2525
raise ProjectNetworkNotFoundError(project_id)
26-
return ProjectsNetworks.from_orm(row)
26+
return ProjectsNetworks.model_validate(row)
2727

2828
async def upsert_projects_networks(
2929
self, project_id: ProjectID, networks_with_aliases: NetworksWithAliases

0 commit comments

Comments
 (0)