From 774ad45efbaad86238004e9a21d4c733f57bde36 Mon Sep 17 00:00:00 2001 From: Maxime Beauchemin Date: Mon, 31 Jul 2017 22:22:08 -0700 Subject: [PATCH] [bugfix] capture Hive job_id pre-url transformation (#3213) --- superset/db_engine_specs.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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: