Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
Peng Gao committed Feb 1, 2024
1 parent afd466e commit 3478c25
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -271,9 +271,7 @@ def generate_datajob(
datajob.properties = job_property_bag
base_url = conf.get("webserver", "base_url")

if (
config and config.datajob_url_link == DatajobUrl.GRID
):
if config and config.datajob_url_link == DatajobUrl.GRID:
datajob.url = f"{base_url}/dags/{datajob.flow_urn.get_flow_id()}/grid?task_id={task.task_id}"
else:
datajob.url = f"{base_url}/taskinstance/list/?flt1_dag_id_equals={datajob.flow_urn.get_flow_id()}&_flt_3_task_id={task.task_id}"
Expand Down

0 comments on commit 3478c25

Please sign in to comment.