diff --git a/superset/db_engine_specs.py b/superset/db_engine_specs.py index b43e94e911f86..f159c7cd6735c 100644 --- a/superset/db_engine_specs.py +++ b/superset/db_engine_specs.py @@ -751,13 +751,13 @@ def handle_cursor(cls, cursor, query, session): if not tracking_url: tracking_url = cls.get_tracking_url(log_lines) if tracking_url: + job_id = tracking_url.split('/')[-2] logging.info( "Found the tracking url: {}".format(tracking_url)) tracking_url = tracking_url_trans(tracking_url) logging.info( "Transformation applied: {}".format(tracking_url)) query.tracking_url = tracking_url - job_id = tracking_url.split('/')[-2] logging.info("Job id: {}".format(job_id)) needs_commit = True if job_id and len(log_lines) > last_log_line: