jprdonnelly/redash
1
0
Fork 0
mirror of https://github.com/getredash/redash.git synced 2026-05-08 09:01:12 -04:00
Code Issues Projects Releases Wiki Activity

keep adhoc job results longer (determined by settings.JOB_EXPIRY_TIME) (#4559)

Browse Source
This commit is contained in:
Omer Lachish
2020-02-09 12:28:58 +02:00
committed by GitHub
parent 69893f0304
commit 7edac9ca89
1 changed files with 13 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
redash/tasks/queries/execution.py
View File

@@ -72,22 +72,25 @@ def enqueue_query(
metadata["Queue"] = queue_name
queue = Queue(queue_name)
job = queue.enqueue(
execute_query,
query,
data_source.id,
metadata,
user_id=user_id,
scheduled_query_id=scheduled_query_id,
is_api_key=is_api_key,
job_timeout=time_limit,
meta={
enqueue_kwargs = {
"user_id": user_id,
"scheduled_query_id": scheduled_query_id,
"is_api_key": is_api_key,
"job_timeout": time_limit,
"meta": {
"data_source_id": data_source.id,
"org_id": data_source.org_id,
"scheduled": scheduled_query_id is not None,
"query_id": metadata.get("Query ID"),
"user_id": user_id,
},
}
if not scheduled_query:
enqueue_kwargs["result_ttl"] = settings.JOB_EXPIRY_TIME
job = queue.enqueue(
execute_query, query, data_source.id, metadata, **enqueue_kwargs
)
logger.info("[%s] Created new job: %s", query_hash, job.id)