From 3032db88d416328b3ae55191cb2a39fd96d86d88 Mon Sep 17 00:00:00 2001 From: Nicolas Burtey Date: Wed, 25 Feb 2026 15:50:06 -0600 Subject: [PATCH] chore(sqlx): trim stale offline query cache files --- ...63b87a60ad88a44541651afaf9f7ef6288435.json | 18 ------- ...2d3a31ee655b14d9f992fd7dcd7ea4559fb49.json | 29 ----------- ...75e0be951ea12e9bcb4c016f93df1575bc8eb.json | 47 ------------------ ...52cdba492d5b44234a941227391ff4ed5c5ce.json | 48 ------------------ ...33624c22189d93a1aeb5b5357f3cf7c3df0a0.json | 15 ------ ...1fede1cef57f46e6b3b07ea414f3066bb911f.json | 15 ------ ...40a624190a3b6b54f29fd1a54f5ed1bc2170b.json | 43 ---------------- ...1fb77556e6a2ccc45d4f1380da0695919b330.json | 26 ---------- ...ea8077430c79520ca26b44f1a7ae74656ad7c.json | 15 ------ ...175cb7288cdc35da02cb706e7cc62936f0523.json | 47 ------------------ ...70be5173a6b992936215300ad0737c46bfeec.json | 17 ------- ...90c8169002ab3bf17d088c3af7628bcc5b35d.json | 47 ------------------ ...bf7d3c4544d08cbb040662537ca75869724b9.json | 17 ------- ...151b67d905c5b481f7c7e13cca53cf9b902cd.json | 47 ------------------ ...a2f031bea0951a2938bcf0b2960179e66879a.json | 48 ------------------ ...de36225e01db0c9998b356239809a9bf227be.json | 22 --------- ...49e4814e2b2eb82675e2226371920e19f1c0d.json | 49 ------------------- ...646ee304f6574e4749f2f1878947b89ce6ae3.json | 15 ------ ...efdaae473009d3dc398aacff73a58eb0e0ad7.json | 16 ------ ...d608a31aa78e73e60e466b7ba47cd9b7a72cd.json | 49 ------------------- 20 files changed, 630 deletions(-) delete mode 100644 cala-server/.sqlx/query-019135648f4d3371f724322403863b87a60ad88a44541651afaf9f7ef6288435.json delete mode 100644 cala-server/.sqlx/query-0ef759ca363dd6215cacf388c8f2d3a31ee655b14d9f992fd7dcd7ea4559fb49.json delete mode 100644 cala-server/.sqlx/query-12668646228f369ad4658bf658e75e0be951ea12e9bcb4c016f93df1575bc8eb.json delete mode 100644 cala-server/.sqlx/query-3d84eec41b105db35e4672b32d352cdba492d5b44234a941227391ff4ed5c5ce.json delete mode 100644 cala-server/.sqlx/query-4aa09bfdf92c1b10f4b533557db33624c22189d93a1aeb5b5357f3cf7c3df0a0.json delete mode 100644 cala-server/.sqlx/query-4ed94ccf82ccc9f8d56e50016d41fede1cef57f46e6b3b07ea414f3066bb911f.json delete mode 100644 cala-server/.sqlx/query-5ea32394be9b2738e7f662c4dcd40a624190a3b6b54f29fd1a54f5ed1bc2170b.json delete mode 100644 cala-server/.sqlx/query-83a57fe9f4eef92fbf7cfb496ae1fb77556e6a2ccc45d4f1380da0695919b330.json delete mode 100644 cala-server/.sqlx/query-9224c1c459a94c2de75e113a109ea8077430c79520ca26b44f1a7ae74656ad7c.json delete mode 100644 cala-server/.sqlx/query-97647c873b103f0c060ab3e73e3175cb7288cdc35da02cb706e7cc62936f0523.json delete mode 100644 cala-server/.sqlx/query-9ab25bea85f68a606013136bf1d70be5173a6b992936215300ad0737c46bfeec.json delete mode 100644 cala-server/.sqlx/query-a13e1721858db65497f99095b4190c8169002ab3bf17d088c3af7628bcc5b35d.json delete mode 100644 cala-server/.sqlx/query-a68768110ff7b74d09822f7ba11bf7d3c4544d08cbb040662537ca75869724b9.json delete mode 100644 cala-server/.sqlx/query-ae139606654819ffd6895252999151b67d905c5b481f7c7e13cca53cf9b902cd.json delete mode 100644 cala-server/.sqlx/query-d58d1b9373f3485a2a4d74567f8a2f031bea0951a2938bcf0b2960179e66879a.json delete mode 100644 cala-server/.sqlx/query-da1731957184bb32791a503e9a0de36225e01db0c9998b356239809a9bf227be.json delete mode 100644 cala-server/.sqlx/query-dcc6c8810ed74de9da3aef674c749e4814e2b2eb82675e2226371920e19f1c0d.json delete mode 100644 cala-server/.sqlx/query-e666d2e28c76cab9ed701d49d72646ee304f6574e4749f2f1878947b89ce6ae3.json delete mode 100644 cala-server/.sqlx/query-e67fb92be8782f30d872b37b7a8efdaae473009d3dc398aacff73a58eb0e0ad7.json delete mode 100644 cala-server/.sqlx/query-fe01de1969256000b4a02e472fbd608a31aa78e73e60e466b7ba47cd9b7a72cd.json diff --git a/cala-server/.sqlx/query-019135648f4d3371f724322403863b87a60ad88a44541651afaf9f7ef6288435.json b/cala-server/.sqlx/query-019135648f4d3371f724322403863b87a60ad88a44541651afaf9f7ef6288435.json deleted file mode 100644 index 097350947..000000000 --- a/cala-server/.sqlx/query-019135648f4d3371f724322403863b87a60ad88a44541651afaf9f7ef6288435.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n INSERT INTO job_executions (id, job_type, queue_id, execute_at, alive_at, created_at)\n VALUES ($1, $2, $3, $4, COALESCE($5, NOW()), COALESCE($5, NOW()))\n ", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Uuid", - "Varchar", - "Varchar", - "Timestamptz", - "Timestamptz" - ] - }, - "nullable": [] - }, - "hash": "019135648f4d3371f724322403863b87a60ad88a44541651afaf9f7ef6288435" -} diff --git a/cala-server/.sqlx/query-0ef759ca363dd6215cacf388c8f2d3a31ee655b14d9f992fd7dcd7ea4559fb49.json b/cala-server/.sqlx/query-0ef759ca363dd6215cacf388c8f2d3a31ee655b14d9f992fd7dcd7ea4559fb49.json deleted file mode 100644 index 5c6545c1c..000000000 --- a/cala-server/.sqlx/query-0ef759ca363dd6215cacf388c8f2d3a31ee655b14d9f992fd7dcd7ea4559fb49.json +++ /dev/null @@ -1,29 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n UPDATE job_executions\n SET state = 'pending',\n execute_at = $1,\n poller_instance_id = NULL\n WHERE poller_instance_id = $2 AND state = 'running'\n RETURNING id as \"id!: JobId\", attempt_index\n ", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "id!: JobId", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "attempt_index", - "type_info": "Int4" - } - ], - "parameters": { - "Left": [ - "Timestamptz", - "Uuid" - ] - }, - "nullable": [ - false, - false - ] - }, - "hash": "0ef759ca363dd6215cacf388c8f2d3a31ee655b14d9f992fd7dcd7ea4559fb49" -} diff --git a/cala-server/.sqlx/query-12668646228f369ad4658bf658e75e0be951ea12e9bcb4c016f93df1575bc8eb.json b/cala-server/.sqlx/query-12668646228f369ad4658bf658e75e0be951ea12e9bcb4c016f93df1575bc8eb.json deleted file mode 100644 index 271214295..000000000 --- a/cala-server/.sqlx/query-12668646228f369ad4658bf658e75e0be951ea12e9bcb4c016f93df1575bc8eb.json +++ /dev/null @@ -1,47 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "WITH entities AS (SELECT id FROM jobs WHERE id = $1) SELECT i.id AS \"entity_id: Repo__Id\", e.sequence, e.event, CASE WHEN $2 THEN e.context ELSE NULL::jsonb END as \"context: es_entity::ContextData\", e.recorded_at FROM entities i JOIN job_events e ON i.id = e.id ORDER BY i.id, e.sequence", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "entity_id: Repo__Id", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "sequence", - "type_info": "Int4" - }, - { - "ordinal": 2, - "name": "event", - "type_info": "Jsonb" - }, - { - "ordinal": 3, - "name": "context: es_entity::ContextData", - "type_info": "Jsonb" - }, - { - "ordinal": 4, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "Uuid", - "Bool" - ] - }, - "nullable": [ - false, - false, - false, - null, - false - ] - }, - "hash": "12668646228f369ad4658bf658e75e0be951ea12e9bcb4c016f93df1575bc8eb" -} diff --git a/cala-server/.sqlx/query-3d84eec41b105db35e4672b32d352cdba492d5b44234a941227391ff4ed5c5ce.json b/cala-server/.sqlx/query-3d84eec41b105db35e4672b32d352cdba492d5b44234a941227391ff4ed5c5ce.json deleted file mode 100644 index b73141bfb..000000000 --- a/cala-server/.sqlx/query-3d84eec41b105db35e4672b32d352cdba492d5b44234a941227391ff4ed5c5ce.json +++ /dev/null @@ -1,48 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "WITH entities AS (SELECT id FROM jobs WHERE (COALESCE(id < $2, true)) ORDER BY id DESC LIMIT $1) SELECT i.id AS \"entity_id: Repo__Id\", e.sequence, e.event, CASE WHEN $3 THEN e.context ELSE NULL::jsonb END as \"context: es_entity::ContextData\", e.recorded_at FROM entities i JOIN job_events e ON i.id = e.id ORDER BY i.id desc, i.id, e.sequence", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "entity_id: Repo__Id", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "sequence", - "type_info": "Int4" - }, - { - "ordinal": 2, - "name": "event", - "type_info": "Jsonb" - }, - { - "ordinal": 3, - "name": "context: es_entity::ContextData", - "type_info": "Jsonb" - }, - { - "ordinal": 4, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "Int8", - "Uuid", - "Bool" - ] - }, - "nullable": [ - false, - false, - false, - null, - false - ] - }, - "hash": "3d84eec41b105db35e4672b32d352cdba492d5b44234a941227391ff4ed5c5ce" -} diff --git a/cala-server/.sqlx/query-4aa09bfdf92c1b10f4b533557db33624c22189d93a1aeb5b5357f3cf7c3df0a0.json b/cala-server/.sqlx/query-4aa09bfdf92c1b10f4b533557db33624c22189d93a1aeb5b5357f3cf7c3df0a0.json deleted file mode 100644 index 868f4a09f..000000000 --- a/cala-server/.sqlx/query-4aa09bfdf92c1b10f4b533557db33624c22189d93a1aeb5b5357f3cf7c3df0a0.json +++ /dev/null @@ -1,15 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n DELETE FROM job_executions\n WHERE id = $1 AND poller_instance_id = $2\n ", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Uuid", - "Uuid" - ] - }, - "nullable": [] - }, - "hash": "4aa09bfdf92c1b10f4b533557db33624c22189d93a1aeb5b5357f3cf7c3df0a0" -} diff --git a/cala-server/.sqlx/query-4ed94ccf82ccc9f8d56e50016d41fede1cef57f46e6b3b07ea414f3066bb911f.json b/cala-server/.sqlx/query-4ed94ccf82ccc9f8d56e50016d41fede1cef57f46e6b3b07ea414f3066bb911f.json deleted file mode 100644 index 36be033cd..000000000 --- a/cala-server/.sqlx/query-4ed94ccf82ccc9f8d56e50016d41fede1cef57f46e6b3b07ea414f3066bb911f.json +++ /dev/null @@ -1,15 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n DELETE FROM job_executions\n WHERE id = $1 AND poller_instance_id = $2\n ", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Uuid", - "Uuid" - ] - }, - "nullable": [] - }, - "hash": "4ed94ccf82ccc9f8d56e50016d41fede1cef57f46e6b3b07ea414f3066bb911f" -} diff --git a/cala-server/.sqlx/query-5ea32394be9b2738e7f662c4dcd40a624190a3b6b54f29fd1a54f5ed1bc2170b.json b/cala-server/.sqlx/query-5ea32394be9b2738e7f662c4dcd40a624190a3b6b54f29fd1a54f5ed1bc2170b.json deleted file mode 100644 index b3d94296f..000000000 --- a/cala-server/.sqlx/query-5ea32394be9b2738e7f662c4dcd40a624190a3b6b54f29fd1a54f5ed1bc2170b.json +++ /dev/null @@ -1,43 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n WITH eligible AS (\n SELECT id, queue_id, execute_at, execution_state_json, attempt_index\n FROM job_executions\n WHERE state = 'pending'\n AND job_type = ANY($4)\n AND NOT EXISTS (\n SELECT 1 FROM job_executions AS running\n WHERE running.state = 'running'\n AND running.queue_id IS NOT NULL\n AND running.queue_id = job_executions.queue_id\n )\n ),\n min_wait AS (\n SELECT MIN(execute_at) - $2::timestamptz AS wait_time\n FROM eligible\n WHERE execute_at > $2::timestamptz\n ),\n candidates AS (\n SELECT id, execution_state_json AS data_json, attempt_index,\n ROW_NUMBER() OVER (\n PARTITION BY COALESCE(queue_id, id::text)\n ORDER BY execute_at\n ) AS rn\n FROM eligible\n WHERE execute_at <= $2::timestamptz\n ),\n selected_jobs AS (\n SELECT je.id, c.data_json, c.attempt_index\n FROM candidates c\n JOIN job_executions je ON je.id = c.id\n WHERE c.rn = 1\n ORDER BY je.execute_at ASC\n LIMIT $1\n FOR UPDATE OF je\n ),\n updated AS (\n UPDATE job_executions AS je\n SET state = 'running', alive_at = $2, execute_at = NULL, poller_instance_id = $3\n FROM selected_jobs\n WHERE je.id = selected_jobs.id\n RETURNING je.id, selected_jobs.data_json, je.attempt_index\n )\n SELECT * FROM (\n SELECT\n u.id AS \"id?: JobId\",\n u.data_json AS \"data_json?: JsonValue\",\n u.attempt_index AS \"attempt_index?\",\n NULL::INTERVAL AS \"max_wait?: PgInterval\"\n FROM updated u\n UNION ALL\n SELECT\n NULL::UUID AS \"id?: JobId\",\n NULL::JSONB AS \"data_json?: JsonValue\",\n NULL::INT AS \"attempt_index?\",\n mw.wait_time AS \"max_wait?: PgInterval\"\n FROM min_wait mw\n WHERE NOT EXISTS (SELECT 1 FROM updated)\n ) AS result\n ", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "id?: JobId", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "data_json?: JsonValue", - "type_info": "Jsonb" - }, - { - "ordinal": 2, - "name": "attempt_index?", - "type_info": "Int4" - }, - { - "ordinal": 3, - "name": "max_wait?: PgInterval", - "type_info": "Interval" - } - ], - "parameters": { - "Left": [ - "Int8", - "Timestamptz", - "Uuid", - "TextArray" - ] - }, - "nullable": [ - null, - null, - null, - null - ] - }, - "hash": "5ea32394be9b2738e7f662c4dcd40a624190a3b6b54f29fd1a54f5ed1bc2170b" -} diff --git a/cala-server/.sqlx/query-83a57fe9f4eef92fbf7cfb496ae1fb77556e6a2ccc45d4f1380da0695919b330.json b/cala-server/.sqlx/query-83a57fe9f4eef92fbf7cfb496ae1fb77556e6a2ccc45d4f1380da0695919b330.json deleted file mode 100644 index 45e85606a..000000000 --- a/cala-server/.sqlx/query-83a57fe9f4eef92fbf7cfb496ae1fb77556e6a2ccc45d4f1380da0695919b330.json +++ /dev/null @@ -1,26 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "INSERT INTO job_events (id, recorded_at, sequence, event_type, event) SELECT $1, COALESCE($2, NOW()), ROW_NUMBER() OVER () + $3, unnested.event_type, unnested.event FROM UNNEST($4::TEXT[], $5::JSONB[]) AS unnested(event_type, event) RETURNING recorded_at", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "Uuid", - "Timestamptz", - "Int8", - "TextArray", - "JsonbArray" - ] - }, - "nullable": [ - false - ] - }, - "hash": "83a57fe9f4eef92fbf7cfb496ae1fb77556e6a2ccc45d4f1380da0695919b330" -} diff --git a/cala-server/.sqlx/query-9224c1c459a94c2de75e113a109ea8077430c79520ca26b44f1a7ae74656ad7c.json b/cala-server/.sqlx/query-9224c1c459a94c2de75e113a109ea8077430c79520ca26b44f1a7ae74656ad7c.json deleted file mode 100644 index 8d42b16c2..000000000 --- a/cala-server/.sqlx/query-9224c1c459a94c2de75e113a109ea8077430c79520ca26b44f1a7ae74656ad7c.json +++ /dev/null @@ -1,15 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n UPDATE job_executions\n SET alive_at = $1\n WHERE poller_instance_id = $2 AND state = 'running'\n ", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Timestamptz", - "Uuid" - ] - }, - "nullable": [] - }, - "hash": "9224c1c459a94c2de75e113a109ea8077430c79520ca26b44f1a7ae74656ad7c" -} diff --git a/cala-server/.sqlx/query-97647c873b103f0c060ab3e73e3175cb7288cdc35da02cb706e7cc62936f0523.json b/cala-server/.sqlx/query-97647c873b103f0c060ab3e73e3175cb7288cdc35da02cb706e7cc62936f0523.json deleted file mode 100644 index f5f9b165a..000000000 --- a/cala-server/.sqlx/query-97647c873b103f0c060ab3e73e3175cb7288cdc35da02cb706e7cc62936f0523.json +++ /dev/null @@ -1,47 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "WITH entities AS (SELECT id FROM jobs WHERE job_type = $1) SELECT i.id AS \"entity_id: Repo__Id\", e.sequence, e.event, CASE WHEN $2 THEN e.context ELSE NULL::jsonb END as \"context: es_entity::ContextData\", e.recorded_at FROM entities i JOIN job_events e ON i.id = e.id ORDER BY i.id, e.sequence", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "entity_id: Repo__Id", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "sequence", - "type_info": "Int4" - }, - { - "ordinal": 2, - "name": "event", - "type_info": "Jsonb" - }, - { - "ordinal": 3, - "name": "context: es_entity::ContextData", - "type_info": "Jsonb" - }, - { - "ordinal": 4, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "Text", - "Bool" - ] - }, - "nullable": [ - false, - false, - false, - null, - false - ] - }, - "hash": "97647c873b103f0c060ab3e73e3175cb7288cdc35da02cb706e7cc62936f0523" -} diff --git a/cala-server/.sqlx/query-9ab25bea85f68a606013136bf1d70be5173a6b992936215300ad0737c46bfeec.json b/cala-server/.sqlx/query-9ab25bea85f68a606013136bf1d70be5173a6b992936215300ad0737c46bfeec.json deleted file mode 100644 index 2838a67d9..000000000 --- a/cala-server/.sqlx/query-9ab25bea85f68a606013136bf1d70be5173a6b992936215300ad0737c46bfeec.json +++ /dev/null @@ -1,17 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n UPDATE job_executions\n SET state = 'pending', execute_at = $2, attempt_index = $3, poller_instance_id = NULL\n WHERE id = $1 AND poller_instance_id = $4\n ", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Uuid", - "Timestamptz", - "Int4", - "Uuid" - ] - }, - "nullable": [] - }, - "hash": "9ab25bea85f68a606013136bf1d70be5173a6b992936215300ad0737c46bfeec" -} diff --git a/cala-server/.sqlx/query-a13e1721858db65497f99095b4190c8169002ab3bf17d088c3af7628bcc5b35d.json b/cala-server/.sqlx/query-a13e1721858db65497f99095b4190c8169002ab3bf17d088c3af7628bcc5b35d.json deleted file mode 100644 index 9aaecf6b7..000000000 --- a/cala-server/.sqlx/query-a13e1721858db65497f99095b4190c8169002ab3bf17d088c3af7628bcc5b35d.json +++ /dev/null @@ -1,47 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "WITH entities AS (SELECT id FROM jobs WHERE id = ANY($1)) SELECT i.id AS \"entity_id: Repo__Id\", e.sequence, e.event, CASE WHEN $2 THEN e.context ELSE NULL::jsonb END as \"context: es_entity::ContextData\", e.recorded_at FROM entities i JOIN job_events e ON i.id = e.id ORDER BY i.id, e.sequence", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "entity_id: Repo__Id", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "sequence", - "type_info": "Int4" - }, - { - "ordinal": 2, - "name": "event", - "type_info": "Jsonb" - }, - { - "ordinal": 3, - "name": "context: es_entity::ContextData", - "type_info": "Jsonb" - }, - { - "ordinal": 4, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "UuidArray", - "Bool" - ] - }, - "nullable": [ - false, - false, - false, - null, - false - ] - }, - "hash": "a13e1721858db65497f99095b4190c8169002ab3bf17d088c3af7628bcc5b35d" -} diff --git a/cala-server/.sqlx/query-a68768110ff7b74d09822f7ba11bf7d3c4544d08cbb040662537ca75869724b9.json b/cala-server/.sqlx/query-a68768110ff7b74d09822f7ba11bf7d3c4544d08cbb040662537ca75869724b9.json deleted file mode 100644 index df2bf0f22..000000000 --- a/cala-server/.sqlx/query-a68768110ff7b74d09822f7ba11bf7d3c4544d08cbb040662537ca75869724b9.json +++ /dev/null @@ -1,17 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "INSERT INTO jobs (id, job_type, unique_per_type, created_at) VALUES ($1, $2, $3, COALESCE($4, NOW()))", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Uuid", - "Varchar", - "Bool", - "Timestamptz" - ] - }, - "nullable": [] - }, - "hash": "a68768110ff7b74d09822f7ba11bf7d3c4544d08cbb040662537ca75869724b9" -} diff --git a/cala-server/.sqlx/query-ae139606654819ffd6895252999151b67d905c5b481f7c7e13cca53cf9b902cd.json b/cala-server/.sqlx/query-ae139606654819ffd6895252999151b67d905c5b481f7c7e13cca53cf9b902cd.json deleted file mode 100644 index 51540a2dc..000000000 --- a/cala-server/.sqlx/query-ae139606654819ffd6895252999151b67d905c5b481f7c7e13cca53cf9b902cd.json +++ /dev/null @@ -1,47 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "WITH entities AS (SELECT id FROM jobs WHERE unique_per_type = $1) SELECT i.id AS \"entity_id: Repo__Id\", e.sequence, e.event, CASE WHEN $2 THEN e.context ELSE NULL::jsonb END as \"context: es_entity::ContextData\", e.recorded_at FROM entities i JOIN job_events e ON i.id = e.id ORDER BY i.id, e.sequence", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "entity_id: Repo__Id", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "sequence", - "type_info": "Int4" - }, - { - "ordinal": 2, - "name": "event", - "type_info": "Jsonb" - }, - { - "ordinal": 3, - "name": "context: es_entity::ContextData", - "type_info": "Jsonb" - }, - { - "ordinal": 4, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "Bool", - "Bool" - ] - }, - "nullable": [ - false, - false, - false, - null, - false - ] - }, - "hash": "ae139606654819ffd6895252999151b67d905c5b481f7c7e13cca53cf9b902cd" -} diff --git a/cala-server/.sqlx/query-d58d1b9373f3485a2a4d74567f8a2f031bea0951a2938bcf0b2960179e66879a.json b/cala-server/.sqlx/query-d58d1b9373f3485a2a4d74567f8a2f031bea0951a2938bcf0b2960179e66879a.json deleted file mode 100644 index 0ab26efe5..000000000 --- a/cala-server/.sqlx/query-d58d1b9373f3485a2a4d74567f8a2f031bea0951a2938bcf0b2960179e66879a.json +++ /dev/null @@ -1,48 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "WITH entities AS (SELECT id FROM jobs WHERE (COALESCE(id > $2, true)) ORDER BY id ASC LIMIT $1) SELECT i.id AS \"entity_id: Repo__Id\", e.sequence, e.event, CASE WHEN $3 THEN e.context ELSE NULL::jsonb END as \"context: es_entity::ContextData\", e.recorded_at FROM entities i JOIN job_events e ON i.id = e.id ORDER BY i.id asc, i.id, e.sequence", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "entity_id: Repo__Id", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "sequence", - "type_info": "Int4" - }, - { - "ordinal": 2, - "name": "event", - "type_info": "Jsonb" - }, - { - "ordinal": 3, - "name": "context: es_entity::ContextData", - "type_info": "Jsonb" - }, - { - "ordinal": 4, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "Int8", - "Uuid", - "Bool" - ] - }, - "nullable": [ - false, - false, - false, - null, - false - ] - }, - "hash": "d58d1b9373f3485a2a4d74567f8a2f031bea0951a2938bcf0b2960179e66879a" -} diff --git a/cala-server/.sqlx/query-da1731957184bb32791a503e9a0de36225e01db0c9998b356239809a9bf227be.json b/cala-server/.sqlx/query-da1731957184bb32791a503e9a0de36225e01db0c9998b356239809a9bf227be.json deleted file mode 100644 index 0069d97f4..000000000 --- a/cala-server/.sqlx/query-da1731957184bb32791a503e9a0de36225e01db0c9998b356239809a9bf227be.json +++ /dev/null @@ -1,22 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n UPDATE job_executions\n SET state = 'pending', execute_at = $1, attempt_index = attempt_index + 1, poller_instance_id = NULL\n WHERE state = 'running' AND alive_at < $1::timestamptz\n RETURNING id as id\n ", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "id", - "type_info": "Uuid" - } - ], - "parameters": { - "Left": [ - "Timestamptz" - ] - }, - "nullable": [ - false - ] - }, - "hash": "da1731957184bb32791a503e9a0de36225e01db0c9998b356239809a9bf227be" -} diff --git a/cala-server/.sqlx/query-dcc6c8810ed74de9da3aef674c749e4814e2b2eb82675e2226371920e19f1c0d.json b/cala-server/.sqlx/query-dcc6c8810ed74de9da3aef674c749e4814e2b2eb82675e2226371920e19f1c0d.json deleted file mode 100644 index c68344916..000000000 --- a/cala-server/.sqlx/query-dcc6c8810ed74de9da3aef674c749e4814e2b2eb82675e2226371920e19f1c0d.json +++ /dev/null @@ -1,49 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "WITH entities AS (SELECT created_at, id FROM jobs WHERE (COALESCE((created_at, id) > ($3, $2), $2 IS NULL)) ORDER BY created_at ASC, id ASC LIMIT $1) SELECT i.id AS \"entity_id: Repo__Id\", e.sequence, e.event, CASE WHEN $4 THEN e.context ELSE NULL::jsonb END as \"context: es_entity::ContextData\", e.recorded_at FROM entities i JOIN job_events e ON i.id = e.id ORDER BY i.created_at asc, i.id asc, i.id, e.sequence", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "entity_id: Repo__Id", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "sequence", - "type_info": "Int4" - }, - { - "ordinal": 2, - "name": "event", - "type_info": "Jsonb" - }, - { - "ordinal": 3, - "name": "context: es_entity::ContextData", - "type_info": "Jsonb" - }, - { - "ordinal": 4, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "Int8", - "Uuid", - "Timestamptz", - "Bool" - ] - }, - "nullable": [ - false, - false, - false, - null, - false - ] - }, - "hash": "dcc6c8810ed74de9da3aef674c749e4814e2b2eb82675e2226371920e19f1c0d" -} diff --git a/cala-server/.sqlx/query-e666d2e28c76cab9ed701d49d72646ee304f6574e4749f2f1878947b89ce6ae3.json b/cala-server/.sqlx/query-e666d2e28c76cab9ed701d49d72646ee304f6574e4749f2f1878947b89ce6ae3.json deleted file mode 100644 index 893ead8f9..000000000 --- a/cala-server/.sqlx/query-e666d2e28c76cab9ed701d49d72646ee304f6574e4749f2f1878947b89ce6ae3.json +++ /dev/null @@ -1,15 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n UPDATE job_executions\n SET execution_state_json = $1\n WHERE id = $2\n ", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Jsonb", - "Uuid" - ] - }, - "nullable": [] - }, - "hash": "e666d2e28c76cab9ed701d49d72646ee304f6574e4749f2f1878947b89ce6ae3" -} diff --git a/cala-server/.sqlx/query-e67fb92be8782f30d872b37b7a8efdaae473009d3dc398aacff73a58eb0e0ad7.json b/cala-server/.sqlx/query-e67fb92be8782f30d872b37b7a8efdaae473009d3dc398aacff73a58eb0e0ad7.json deleted file mode 100644 index edf8a0bb8..000000000 --- a/cala-server/.sqlx/query-e67fb92be8782f30d872b37b7a8efdaae473009d3dc398aacff73a58eb0e0ad7.json +++ /dev/null @@ -1,16 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "\n UPDATE job_executions\n SET state = 'pending', execute_at = $2, attempt_index = 1, poller_instance_id = NULL\n WHERE id = $1 AND poller_instance_id = $3\n ", - "describe": { - "columns": [], - "parameters": { - "Left": [ - "Uuid", - "Timestamptz", - "Uuid" - ] - }, - "nullable": [] - }, - "hash": "e67fb92be8782f30d872b37b7a8efdaae473009d3dc398aacff73a58eb0e0ad7" -} diff --git a/cala-server/.sqlx/query-fe01de1969256000b4a02e472fbd608a31aa78e73e60e466b7ba47cd9b7a72cd.json b/cala-server/.sqlx/query-fe01de1969256000b4a02e472fbd608a31aa78e73e60e466b7ba47cd9b7a72cd.json deleted file mode 100644 index 0b09d1102..000000000 --- a/cala-server/.sqlx/query-fe01de1969256000b4a02e472fbd608a31aa78e73e60e466b7ba47cd9b7a72cd.json +++ /dev/null @@ -1,49 +0,0 @@ -{ - "db_name": "PostgreSQL", - "query": "WITH entities AS (SELECT created_at, id FROM jobs WHERE (COALESCE((created_at, id) < ($3, $2), $2 IS NULL)) ORDER BY created_at DESC, id DESC LIMIT $1) SELECT i.id AS \"entity_id: Repo__Id\", e.sequence, e.event, CASE WHEN $4 THEN e.context ELSE NULL::jsonb END as \"context: es_entity::ContextData\", e.recorded_at FROM entities i JOIN job_events e ON i.id = e.id ORDER BY i.created_at desc, i.id desc, i.id, e.sequence", - "describe": { - "columns": [ - { - "ordinal": 0, - "name": "entity_id: Repo__Id", - "type_info": "Uuid" - }, - { - "ordinal": 1, - "name": "sequence", - "type_info": "Int4" - }, - { - "ordinal": 2, - "name": "event", - "type_info": "Jsonb" - }, - { - "ordinal": 3, - "name": "context: es_entity::ContextData", - "type_info": "Jsonb" - }, - { - "ordinal": 4, - "name": "recorded_at", - "type_info": "Timestamptz" - } - ], - "parameters": { - "Left": [ - "Int8", - "Uuid", - "Timestamptz", - "Bool" - ] - }, - "nullable": [ - false, - false, - false, - null, - false - ] - }, - "hash": "fe01de1969256000b4a02e472fbd608a31aa78e73e60e466b7ba47cd9b7a72cd" -}