1818import json
1919from uuid import UUID , uuid4
2020
21- from sqlalchemy import create_engine , engine , insert , select , update
21+ from sqlalchemy import create_engine , insert , select , update
22+ from sqlalchemy .engine import Engine
2223
2324from exec_manager .dao .db_models import DBJob , metadata
2425from exec_manager .exec_profile import ExecProfile
@@ -36,7 +37,7 @@ def create_job_dao(
3637 exec_profile : ExecProfile ,
3738 workflow : dict ,
3839 inputs : dict ,
39- db_engine : engine = DB_ENGINE ,
40+ db_engine : Engine = DB_ENGINE ,
4041) -> UUID :
4142 """
4243 Inserts a job into the database.
@@ -77,7 +78,7 @@ def create_job_dao(
7778 return job_id
7879
7980
80- def get_job (job_id : UUID , db_engine : engine = DB_ENGINE ) -> Job :
81+ def get_job (job_id : UUID , db_engine : Engine = DB_ENGINE ) -> Job :
8182 """
8283 Returns a job by his job id.
8384
@@ -109,7 +110,7 @@ def get_job(job_id: UUID, db_engine: engine = DB_ENGINE) -> Job:
109110
110111
111112def update_job_status (
112- job_id : UUID , new_job_status : JobStatusType , db_engine : engine = DB_ENGINE
113+ job_id : UUID , new_job_status : JobStatusType , db_engine : Engine = DB_ENGINE
113114) -> None :
114115 """
115116 Updates a jobs status by his job id.
0 commit comments