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.

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

[WIP][SMTR] Adiciona flow de cancelamento de runs agendadas de versões arquivadas dos flows #626

Open
wants to merge 10 commits into
base: master
Choose a base branch
from
Prev Previous commit
Next Next commit
remove unused code
Hellcassius committed Feb 1, 2024
commit 2367e470e1e34232f05cf6c39451f0407bd7910d
5 changes: 0 additions & 5 deletions pipelines/rj_smtr/janitor/tasks.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
# -*- coding: utf-8 -*-
from typing import Dict, List

import pendulum
from prefect import task
from prefect.client import Client

@@ -105,11 +104,7 @@ def query_archived_scheduled_runs(flow_name, prefect_client=None):
log(
f"Got flow_run {flow_run['id']}, scheduled: {flow_run['scheduled_start_time']}"
)
# while len(response):
# if len(response["flow"]["flow_runs"]):

# variables["offset"] += len(response)
# response = prefect_client.graphql(query=query, variables=variables)
if archived_flow_runs:
log(f"O Flow {flow_name} possui runs a serem canceladas")
return {"flow_name": flow_name, "flow_runs": archived_flow_runs}