Skip to content

Commit

Permalink
Solving small problem and bump version
Browse files Browse the repository at this point in the history
  • Loading branch information
AlejandraGalan committed Oct 31, 2024
1 parent 2909168 commit 5145d38
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions libs/client/cornflow_client/airflow/api.py
Original file line number Diff line number Diff line change
Expand Up @@ -111,10 +111,10 @@ def set_dag_run_to_fail(self, dag_name, dag_run_id, new_status="failed"):
def get_all_dag_runs(self, dag_name):
return self.consume_dag_run(dag_name=dag_name, payload=None, method="GET")

def get_orch_info(self, orch_name, method="GET"):
def get_orch_info(self, orch_name, method="GET"):
url = f"{self.url}/dags/{orch_name}"
schema_info = self.request_headers_auth(method=method, url=url)
if schema_info.status_code!=200:
schema_info = self.request_headers_auth(method=method, url=url)
if schema_info.status_code != 200:
raise AirflowError("DAG not available")
return schema_info

Expand Down
2 changes: 1 addition & 1 deletion libs/client/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@

setuptools.setup(
name="cornflow-client",
version="2.0.0a1",
version="2.0.0a2",
author="baobab soluciones",
author_email="[email protected]",
description="Client to connect to a cornflow server",
Expand Down

0 comments on commit 5145d38

Please sign in to comment.