Skip to content

Phiphi: flow_runner_flow: hook up to database

Daniel Burkhardt Cerigo requested to merge data_pipeline/flow_runner_flow into main

Implements the actual working version of the flow_runner_flow.

Currently failing mypy with:

Running mypy command: mypy projects/phiphi/ --no-incremental
projects/phiphi/phiphi/api/projects/job_runs/flow_runner_flow.py:29: error: "Generator[Session, None, None]" has no attribute "__enter__"; maybe "__iter__"?  [attr-defined]
projects/phiphi/phiphi/api/projects/job_runs/flow_runner_flow.py:29: error: "Generator[Session, None, None]" has no attribute "__exit__"; maybe "__next__"?  [attr-defined]
projects/phiphi/phiphi/api/projects/job_runs/flow_runner_flow.py:102: error: "Generator[Session, None, None]" has no attribute "__enter__"; maybe "__iter__"?  [attr-defined]
projects/phiphi/phiphi/api/projects/job_runs/flow_runner_flow.py:102: error: "Generator[Session, None, None]" has no attribute "__exit__"; maybe "__next__"?  [attr-defined]
projects/phiphi/phiphi/api/projects/job_runs/flow_runner_flow.py:124: error: "Generator[Session, None, None]" has no attribute "__enter__"; maybe "__iter__"?  [attr-defined]
projects/phiphi/phiphi/api/projects/job_runs/flow_runner_flow.py:124: error: "Generator[Session, None, None]" has no attribute "__exit__"; maybe "__next__"?  [attr-defined]
Found 6 errors in 1 file (checked 97 source files)

Due to lines as:

        with platform_db.get_session() as session:

@benjamincerigo any ideas on how platform_db.get_session() should actually be used?

Edited by Daniel Burkhardt Cerigo

Merge request reports