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