From 12c3cc57c7dda80a2601b5d6b910c2417904332f Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Fri, 5 Apr 2024 02:08:40 -0700 Subject: [PATCH] nit Signed-off-by: Kevin Su --- plugins/flytekit-airflow/flytekitplugins/airflow/agent.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugins/flytekit-airflow/flytekitplugins/airflow/agent.py b/plugins/flytekit-airflow/flytekitplugins/airflow/agent.py index 362d4be3b4..76fdf9abd8 100644 --- a/plugins/flytekit-airflow/flytekitplugins/airflow/agent.py +++ b/plugins/flytekit-airflow/flytekitplugins/airflow/agent.py @@ -137,7 +137,7 @@ async def get(self, resource_meta: AirflowMetadata, **kwargs) -> Resource: return Resource( phase=cur_phase, message=message, - log_links=get_log_links(airflow_operator_instance, resource_meta.airflow_operator.parameters), + log_links=get_log_links(airflow_operator_instance, airflow_trigger_instance), ) async def delete(self, resource_meta: AirflowMetadata, **kwargs):