|
|
@@ -37,10 +37,11 @@ class RunStepService:
|
|
|
|
|
|
@staticmethod
|
|
|
def get_run_step_list(*, run_id, thread_id, session: Session) -> List[RunStep]:
|
|
|
+ session.commit()
|
|
|
statement = select(RunStep).where(RunStep.run_id == run_id).where(RunStep.thread_id == thread_id)
|
|
|
- logging.info("statement: %s", statement)
|
|
|
- return session.execute(statement).scalars().all()
|
|
|
-
|
|
|
+ result = session.execute(statement).scalars().all()
|
|
|
+ logging.info("result: %s", result)
|
|
|
+ return result
|
|
|
@staticmethod
|
|
|
def to_cancelled(*, session: Session, run_step_id) -> RunStep:
|
|
|
run_step = RunStepService.get_run_step(run_step_id=run_step_id, session=session)
|
