DROP FUNCTION IF EXISTS {SCHEMA_NAME}._set_job_processing(job_id BIGINT); – removed in 0.5.0 CREATE OR REPLACE FUNCTION {SCHEMA_NAME}._set_job_processing(worker_session_id UUID, job_id BIGINT) RETURNS VOID AS $$ DECLARE

v_pid int;
v_host_id uuid;

BEGIN

v_pid := pg_backend_pid();
SELECT host_id INTO v_host_id FROM {SCHEMA_NAME}.worker_sessions WHERE id=worker_session_id;

UPDATE {SCHEMA_NAME}.postjobs
SET
  last_worker_session_id=worker_session_id,
  status='processing',
  error=NULL,
  error_message=NULL,
  error_backtrace=NULL,
  next_run_at=NULL,
  sticky_host_id=(CASE WHEN is_sticky THEN v_host_id ELSE NULL END)
WHERE id=job_id;

END; $$ LANGUAGE plpgsql;

DROP FUNCTION IF EXISTS {SCHEMA_NAME}._reset_job_processing(job_id BIGINT); – removed in 0.5.0 CREATE OR REPLACE FUNCTION {SCHEMA_NAME}._reset_job_processing(worker_session_id UUID, job_id BIGINT) RETURNS VOID AS $$ BEGIN

UPDATE {SCHEMA_NAME}.postjobs
SET
  last_worker_session_id=worker_session_id
WHERE id=job_id;

END; $$ LANGUAGE plpgsql;