[go: up one dir, main page]
Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[dy] Optimize pipeline schedules LIST api #4058

Merged
merged 13 commits into from
Dec 8, 2023
Merged

[dy] Optimize pipeline schedules LIST api #4058

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
023dcd9
[dy] Update pipeline schedules queries
dy46 Nov 20, 2023
537b8bf
[dy] Update pipeline schedule list api
dy46 Nov 22, 2023
79f6144
[dy] Fix policy
dy46 Nov 22, 2023
bfdc6a3
[dy] Add comments
dy46 Nov 22, 2023
c9b32c6
[dy] Update last pipeline run status
dy46 Dec 8, 2023
0a89877
[dy] Batch pipeline run fetch
dy46 Dec 8, 2023
c10a003
[dy] Update comments
dy46 Dec 8, 2023
1b8c0c7
[dy] Optimize query further
dy46 Dec 8, 2023
6942e3c
[dy] Remove print log
dy46 Dec 8, 2023
c7f5dd0
[dy] Fix order
dy46 Dec 8, 2023
5c7cc6b
[dy] Remove event matchers from presenter
dy46 Dec 8, 2023
d3c82a8
[dy] Add event matchers back
dy46 Dec 8, 2023
b87d11c
[dy] Show 0 in table
dy46 Dec 8, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
[dy] Update comments
  • Loading branch information
@dy46
dy46 committed Dec 8, 2023
commit c10a0039131cbf602452bc2c86cbc74b90d6f4e4
6 changes: 3 additions & 3 deletions mage_ai/api/resources/PipelineScheduleResource.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -143,9 +143,9 @@ def collection(self, query_arg, meta, user, **kwargs):
schedules = query.all()
schedule_ids = [schedule.id for schedule in schedules]

# Get the number of pipeline runs and in progress pipeline runs for each pipeline schedule
# in a single query. The result of this query will be a record of
# (pipeline_schedule_id, pipeline_runs_count, in_progress_runs_count).
# Get fields to be returned in a single query. The result of this query
# will be a record of (pipeline_schedule_id, pipeline_runs_count,
# in_progress_runs_count, last_pipeline_run_id).
counts_query = (
PipelineRun.select(
PipelineRun.pipeline_schedule_id,
Expand Down
Loading