feat(chalice): debugging jobs execution

This commit is contained in:
Taha Yassine Kraiem 2023-04-12 13:37:16 +01:00 committed by rjshrjndrn
parent 9d6daf09a2
commit 5b8d095764
2 changed files with 7 additions and 8 deletions

View file

@ -106,17 +106,13 @@ def format_datetime(r):
def get_scheduled_jobs():
with pg_client.PostgresClient() as cur:
query = cur.mogrify(
"""SELECT * FROM public.jobs
WHERE status = %(status)s AND start_at <= (now() at time zone 'utc');""",
"""SELECT *
FROM public.jobs
WHERE status = %(status)s
AND start_at <= (now() at time zone 'utc');""",
{"status": JobStatus.SCHEDULED})
print("------------------")
print(query)
print("------------------")
cur.execute(query=query)
data = cur.fetchall()
for record in data:
format_datetime(record)
return helper.list_to_camel_case(data)

View file

@ -1073,6 +1073,9 @@ def get_session_ids_by_user_ids(project_id, user_ids):
WHERE project_id = %(project_id)s
AND user_id IN %(userId)s;""",
{"project_id": project_id, "userId": tuple(user_ids)})
print("----------")
print(query)
print("----------")
cur.execute(query=query)
ids = cur.fetchall()
return [s["session_id"] for s in ids]