From 1b264ea6bdad8b916e0a6fe51009cd8d86d03680 Mon Sep 17 00:00:00 2001 From: Dylan Leard Date: Fri, 19 Jun 2020 15:13:21 -0700 Subject: [PATCH] feat: update function logic --- .../database_functions/graphile_worker_job_definer_001.sql | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/schema/deploy/database_functions/graphile_worker_job_definer_001.sql b/schema/deploy/database_functions/graphile_worker_job_definer_001.sql index 488767498a..aa084be0a7 100644 --- a/schema/deploy/database_functions/graphile_worker_job_definer_001.sql +++ b/schema/deploy/database_functions/graphile_worker_job_definer_001.sql @@ -9,11 +9,11 @@ returns void as $$ calls_past_minute int; defer_run_multiplier int; begin - insert into ggircs_portal_private.graphile_worker_timestamp(called_at) values (now()); - calls_past_minute := (select count(*) from ggircs_portal_private.graphile_worker_timestamp where called_at between (now() - interval '1 minute') and now()); + calls_past_minute := (select count(*) from ggircs_portal_private.graphile_worker_timestamp where called_at > (now() - interval '1 minute')); defer_run_multiplier := (calls_past_minute/100); - perform graphile_worker.add_job(task, payload, run_at := NOW() + ((defer_run_multiplier) * INTERVAL '1 minute')); + perform graphile_worker.add_job(task, payload, run_at := now() + ((defer_run_multiplier) * INTERVAL '1 minute')); + insert into ggircs_portal_private.graphile_worker_timestamp(called_at) values (now() + ((defer_run_multiplier) * INTERVAL '1 minute')); end; $$ language plpgsql volatile security definer;