small fix

Author: rishikeshdevsot

components/job-orchestration/job_orchestration/executor/query/utils.py

@@ -89,13 +89,6 @@ def sigterm_handler(_signo, _stack_frame):
     stdout_data, _ = task_proc.communicate()
     return_code = task_proc.returncode
 
-    # Dump the stderr log so it's visible in container logs
-    if clo_log_path.stat().st_size > 0:
-        logger.error(
-            f"Contents of {clo_log_path.name}:\n"
-            f"{clo_log_path.read_text()}"
-        )
-
     if 0 != return_code:
         task_status = QueryTaskStatus.FAILED
         logger.error(
@@ -106,6 +99,12 @@ def sigterm_handler(_signo, _stack_frame):
         logger.info(f"{task_name} task {task_id} completed for job {job_id}")
 
     clo_log_file.close()
+    # Dump the stderr log so it's visible in container logs
+    if clo_log_path.stat().st_size > 0:
+        logger.error(
+            f"Contents of {clo_log_path.name}:\n"
+            f"{clo_log_path.read_text()}"
+        )
     duration = (datetime.datetime.now() - start_time).total_seconds()
 
     update_query_task_metadata(