valitydev/redash
14
0
Fork 0
mirror of https://github.com/valitydev/redash.git synced 2024-11-07 01:25:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Run annotated queries.

Browse Source
This commit is contained in:
Arik Fraimovich 2013-12-17 12:03:10 +02:00
parent 6e0d1c613c
commit f08ebf2256
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
rd_service/data/worker.py
View File

@ -225,12 +225,17 @@ class Worker(threading.Thread):
logging.warning("[%s][%s] tried to process finished job.", self.name, job)
return
job.processing(os.getpid())
pid = os.getpid()
job.processing(pid)
logging.info("[%s][%s] running query...", self.name, job.id)
start_time = time.time()
self.set_title("running query %s" % job_id)
data, error = self.query_runner(job.query)
annotated_query = "/* Pid: %s, Job Id: %s, Query hash: %s, Priority: %s */ %s" % \
(pid, job.id, job.query_hash, job.priority, job.query)
data, error = self.query_runner(annotated_query)
run_time = time.time() - start_time
logging.info("[%s][%s] query finished... data length=%s, error=%s",
self.name, job.id, data and len(data), error)