diff --git a/Cargo.toml b/Cargo.toml index 5dc6bab..c519e62 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -9,7 +9,7 @@ members = [ ] [workspace.package] -version = "0.35.1" +version = "0.35.2" [workspace.lints.clippy] cargo = { level = "warn", priority = -1 } diff --git a/nix/sources.json b/nix/sources.json index 2a551c6..bd07fbc 100644 --- a/nix/sources.json +++ b/nix/sources.json @@ -5,10 +5,10 @@ "homepage": "https://crane.dev", "owner": "ipetkov", "repo": "crane", - "rev": "0bda7e7d005ccb5522a76d11ccfbf562b71953ca", - "sha256": "1ndhiw867qiwr3kswm2mb81y3xcfdwz92xvs00r6jd4blxsv7z09", + "rev": "5e0fb2f64edff2822249f21293b8304dedaaf676", + "sha256": "0mqw6ibknf1845ygfq28h16655a4zd2r18bigqr0n0rih333jj3c", "type": "tarball", - "url": "https://github.com/ipetkov/crane/archive/0bda7e7d005ccb5522a76d11ccfbf562b71953ca.tar.gz", + "url": "https://github.com/ipetkov/crane/archive/5e0fb2f64edff2822249f21293b8304dedaaf676.tar.gz", "url_template": "https://github.com///archive/.tar.gz" }, "nixpkgs": { @@ -29,10 +29,10 @@ "homepage": "", "owner": "oxalica", "repo": "rust-overlay", - "rev": "71f9daa4e05e49c434d08627e755495ae222bc34", - "sha256": "1vdqw008wza6vx823hd5wb7my72fhj006i1695mbvg0kfl7dh5z2", + "rev": "146e7bf7569b8288f24d41d806b9f584f7cfd5b5", + "sha256": "1px2kyr2ngg633cljxz3891dkiyzmi1mbjb4hpbwl8k278d74p51", "type": "tarball", - "url": "https://github.com/oxalica/rust-overlay/archive/71f9daa4e05e49c434d08627e755495ae222bc34.tar.gz", + "url": "https://github.com/oxalica/rust-overlay/archive/146e7bf7569b8288f24d41d806b9f584f7cfd5b5.tar.gz", "url_template": "https://github.com///archive/.tar.gz" } } diff --git a/opsqueue/.sqlx/query-08fd98126c44dcbd07eb449d09e238c6ea5d468ba73a8b4b1d5f2df9e4bd39b0.json b/opsqueue/.sqlx/query-08fd98126c44dcbd07eb449d09e238c6ea5d468ba73a8b4b1d5f2df9e4bd39b0.json deleted file mode 100644 index 1999ee0..0000000 --- a/opsqueue/.sqlx/query-08fd98126c44dcbd07eb449d09e238c6ea5d468ba73a8b4b1d5f2df9e4bd39b0.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT metadata_key, metadata_value FROM chunks_metadata\n WHERE submission_id = $1 AND chunk_index = $2\n ", - "describe": { - "columns": [ - { - "name": "metadata_key", - "ordinal": 0, - "type_info": "Text" - }, - { - "name": "metadata_value", - "ordinal": 1, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 2 - }, - "nullable": [false, false] - }, - "hash": "08fd98126c44dcbd07eb449d09e238c6ea5d468ba73a8b4b1d5f2df9e4bd39b0" -} diff --git a/opsqueue/.sqlx/query-0f5c290f571f139bc5651240ec05a9da0a4e3a22d1291bc431afe6b976156ca5.json b/opsqueue/.sqlx/query-0f5c290f571f139bc5651240ec05a9da0a4e3a22d1291bc431afe6b976156ca5.json deleted file mode 100644 index 7e11e91..0000000 --- a/opsqueue/.sqlx/query-0f5c290f571f139bc5651240ec05a9da0a4e3a22d1291bc431afe6b976156ca5.json +++ /dev/null @@ -1,48 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n INSERT INTO submissions_failed\n (id, chunks_total, prefix, metadata, failed_at, failed_chunk_id)\n SELECT id, chunks_total, prefix, metadata, julianday($1), $2 FROM submissions WHERE id = $3;\n\n DELETE FROM submissions WHERE id = $4 RETURNING *;\n ", - "describe": { - "columns": [ - { - "name": "id", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "prefix", - "ordinal": 1, - "type_info": "Text" - }, - { - "name": "chunks_total", - "ordinal": 2, - "type_info": "Integer" - }, - { - "name": "chunks_done", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "metadata", - "ordinal": 4, - "type_info": "Blob" - }, - { - "name": "otel_trace_carrier", - "ordinal": 5, - "type_info": "Text" - }, - { - "name": "chunk_size", - "ordinal": 6, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 4 - }, - "nullable": [false, true, false, false, true, false, true] - }, - "hash": "0f5c290f571f139bc5651240ec05a9da0a4e3a22d1291bc431afe6b976156ca5" -} diff --git a/opsqueue/.sqlx/query-11d4e8c27b08ec013a154838137bab496b9e37ce482189f38eef19b20fc447f4.json b/opsqueue/.sqlx/query-11d4e8c27b08ec013a154838137bab496b9e37ce482189f38eef19b20fc447f4.json deleted file mode 100644 index 502dfc8..0000000 --- a/opsqueue/.sqlx/query-11d4e8c27b08ec013a154838137bab496b9e37ce482189f38eef19b20fc447f4.json +++ /dev/null @@ -1,33 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT\n submission_id AS \"submission_id: SubmissionId\"\n , chunk_index AS \"chunk_index: ChunkIndex\"\n , input_content\n , retries\n FROM chunks WHERE submission_id = $1 AND chunk_index = $2\n ", - "describe": { - "columns": [ - { - "name": "submission_id: SubmissionId", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "chunk_index: ChunkIndex", - "ordinal": 1, - "type_info": "Integer" - }, - { - "name": "input_content", - "ordinal": 2, - "type_info": "Blob" - }, - { - "name": "retries", - "ordinal": 3, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 2 - }, - "nullable": [false, false, true, false] - }, - "hash": "11d4e8c27b08ec013a154838137bab496b9e37ce482189f38eef19b20fc447f4" -} diff --git a/opsqueue/.sqlx/query-13b72b517c04819669c5139d0a823e1d009a0612eeecf94ec68401d36d5434e1.json b/opsqueue/.sqlx/query-13b72b517c04819669c5139d0a823e1d009a0612eeecf94ec68401d36d5434e1.json deleted file mode 100644 index 60f8a28..0000000 --- a/opsqueue/.sqlx/query-13b72b517c04819669c5139d0a823e1d009a0612eeecf94ec68401d36d5434e1.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "DELETE FROM submissions_metadata\n WHERE submission_id = (\n SELECT id FROM submissions_failed WHERE failed_at < julianday($1)\n );", - "describe": { - "columns": [], - "parameters": { - "Right": 1 - }, - "nullable": [] - }, - "hash": "13b72b517c04819669c5139d0a823e1d009a0612eeecf94ec68401d36d5434e1" -} diff --git a/opsqueue/.sqlx/query-17ef938e2fc0ac7bdc09690094b055db5edcb4af140151dc389548d010de4b5f.json b/opsqueue/.sqlx/query-17ef938e2fc0ac7bdc09690094b055db5edcb4af140151dc389548d010de4b5f.json deleted file mode 100644 index e475140..0000000 --- a/opsqueue/.sqlx/query-17ef938e2fc0ac7bdc09690094b055db5edcb4af140151dc389548d010de4b5f.json +++ /dev/null @@ -1,48 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT\n id AS \"id: SubmissionId\"\n , prefix\n , chunks_total AS \"chunks_total: ChunkCount\"\n , chunk_size AS \"chunk_size: ChunkSize\"\n , metadata\n , completed_at AS \"completed_at: DateTime\"\n , otel_trace_carrier\n FROM submissions_completed WHERE id = $1\n ", - "describe": { - "columns": [ - { - "name": "id: SubmissionId", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "prefix", - "ordinal": 1, - "type_info": "Text" - }, - { - "name": "chunks_total: ChunkCount", - "ordinal": 2, - "type_info": "Integer" - }, - { - "name": "chunk_size: ChunkSize", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "metadata", - "ordinal": 4, - "type_info": "Blob" - }, - { - "name": "completed_at: DateTime", - "ordinal": 5, - "type_info": "Datetime" - }, - { - "name": "otel_trace_carrier", - "ordinal": 6, - "type_info": "Text" - } - ], - "parameters": { - "Right": 1 - }, - "nullable": [false, true, false, true, true, false, false] - }, - "hash": "17ef938e2fc0ac7bdc09690094b055db5edcb4af140151dc389548d010de4b5f" -} diff --git a/opsqueue/.sqlx/query-18f783ff8500f06825c985530486c0624c112f61a5816d4c4528f9b3151713e4.json b/opsqueue/.sqlx/query-18f783ff8500f06825c985530486c0624c112f61a5816d4c4528f9b3151713e4.json deleted file mode 100644 index b84195d..0000000 --- a/opsqueue/.sqlx/query-18f783ff8500f06825c985530486c0624c112f61a5816d4c4528f9b3151713e4.json +++ /dev/null @@ -1,48 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT id AS \"id: SubmissionId\"\n , prefix\n , chunks_total AS \"chunks_total: ChunkCount\"\n , chunks_done AS \"chunks_done: ChunkCount\"\n , chunk_size AS \"chunk_size: ChunkSize\"\n , metadata\n , otel_trace_carrier\n FROM submissions WHERE id = $1\n ", - "describe": { - "columns": [ - { - "name": "id: SubmissionId", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "prefix", - "ordinal": 1, - "type_info": "Text" - }, - { - "name": "chunks_total: ChunkCount", - "ordinal": 2, - "type_info": "Integer" - }, - { - "name": "chunks_done: ChunkCount", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "chunk_size: ChunkSize", - "ordinal": 4, - "type_info": "Integer" - }, - { - "name": "metadata", - "ordinal": 5, - "type_info": "Blob" - }, - { - "name": "otel_trace_carrier", - "ordinal": 6, - "type_info": "Text" - } - ], - "parameters": { - "Right": 1 - }, - "nullable": [false, true, false, false, true, true, false] - }, - "hash": "18f783ff8500f06825c985530486c0624c112f61a5816d4c4528f9b3151713e4" -} diff --git a/opsqueue/.sqlx/query-1b3e8cc0730f75e690337f1834d28d8ae98d1fb97195f47c36a7c45038edb7e8.json b/opsqueue/.sqlx/query-1b3e8cc0730f75e690337f1834d28d8ae98d1fb97195f47c36a7c45038edb7e8.json deleted file mode 100644 index 9d1b07a..0000000 --- a/opsqueue/.sqlx/query-1b3e8cc0730f75e690337f1834d28d8ae98d1fb97195f47c36a7c45038edb7e8.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "DELETE FROM submissions_metadata\n WHERE submission_id = (\n SELECT id FROM submissions_completed WHERE completed_at < julianday($1)\n );", - "describe": { - "columns": [], - "parameters": { - "Right": 1 - }, - "nullable": [] - }, - "hash": "1b3e8cc0730f75e690337f1834d28d8ae98d1fb97195f47c36a7c45038edb7e8" -} diff --git a/opsqueue/.sqlx/query-207eb97fe104f49008ebe798860f6340f180a1afde82dd1c08dc4b2b650fbfe2.json b/opsqueue/.sqlx/query-207eb97fe104f49008ebe798860f6340f180a1afde82dd1c08dc4b2b650fbfe2.json deleted file mode 100644 index f0c2f70..0000000 --- a/opsqueue/.sqlx/query-207eb97fe104f49008ebe798860f6340f180a1afde82dd1c08dc4b2b650fbfe2.json +++ /dev/null @@ -1,33 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT\n submission_id AS \"submission_id: SubmissionId\"\n , chunk_index AS \"chunk_index: ChunkIndex\"\n , output_content\n , completed_at AS \"completed_at: DateTime\"\n FROM chunks_completed WHERE submission_id = $1 AND chunk_index = $2\n ", - "describe": { - "columns": [ - { - "name": "submission_id: SubmissionId", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "chunk_index: ChunkIndex", - "ordinal": 1, - "type_info": "Integer" - }, - { - "name": "output_content", - "ordinal": 2, - "type_info": "Blob" - }, - { - "name": "completed_at: DateTime", - "ordinal": 3, - "type_info": "Datetime" - } - ], - "parameters": { - "Right": 2 - }, - "nullable": [false, false, true, false] - }, - "hash": "207eb97fe104f49008ebe798860f6340f180a1afde82dd1c08dc4b2b650fbfe2" -} diff --git a/opsqueue/.sqlx/query-2b77ed3badfb9fe0fd7b88635ef9d11f88e91b1cfcef1d93e814ab2da07addcb.json b/opsqueue/.sqlx/query-2b77ed3badfb9fe0fd7b88635ef9d11f88e91b1cfcef1d93e814ab2da07addcb.json deleted file mode 100644 index b724699..0000000 --- a/opsqueue/.sqlx/query-2b77ed3badfb9fe0fd7b88635ef9d11f88e91b1cfcef1d93e814ab2da07addcb.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "SELECT COUNT(1) as count FROM chunks_failed;", - "describe": { - "columns": [ - { - "name": "count", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [false] - }, - "hash": "2b77ed3badfb9fe0fd7b88635ef9d11f88e91b1cfcef1d93e814ab2da07addcb" -} diff --git a/opsqueue/.sqlx/query-3d130615a116adca109be4759b7690ad2ca3ddd1912e1539bdc209f51a2282aa.json b/opsqueue/.sqlx/query-3d130615a116adca109be4759b7690ad2ca3ddd1912e1539bdc209f51a2282aa.json deleted file mode 100644 index d65bc72..0000000 --- a/opsqueue/.sqlx/query-3d130615a116adca109be4759b7690ad2ca3ddd1912e1539bdc209f51a2282aa.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "DELETE FROM submissions_completed WHERE completed_at < julianday($1);", - "describe": { - "columns": [], - "parameters": { - "Right": 1 - }, - "nullable": [] - }, - "hash": "3d130615a116adca109be4759b7690ad2ca3ddd1912e1539bdc209f51a2282aa" -} diff --git a/opsqueue/.sqlx/query-3dde3eaab357df88cd1c0e0e8e833aca1fce450c2d842a2af63f0e4c128424f7.json b/opsqueue/.sqlx/query-3dde3eaab357df88cd1c0e0e8e833aca1fce450c2d842a2af63f0e4c128424f7.json deleted file mode 100644 index 64daa6a..0000000 --- a/opsqueue/.sqlx/query-3dde3eaab357df88cd1c0e0e8e833aca1fce450c2d842a2af63f0e4c128424f7.json +++ /dev/null @@ -1,48 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SAVEPOINT complete_submission_raw;\n\n INSERT INTO submissions_completed\n (id, chunks_total, prefix, metadata, completed_at)\n SELECT id, chunks_total, prefix, metadata, julianday($1) FROM submissions WHERE id = $2;\n\n DELETE FROM submissions WHERE id = $3 RETURNING *;\n\n RELEASE SAVEPOINT complete_submission_raw;\n ", - "describe": { - "columns": [ - { - "name": "id", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "prefix", - "ordinal": 1, - "type_info": "Text" - }, - { - "name": "chunks_total", - "ordinal": 2, - "type_info": "Integer" - }, - { - "name": "chunks_done", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "metadata", - "ordinal": 4, - "type_info": "Blob" - }, - { - "name": "otel_trace_carrier", - "ordinal": 5, - "type_info": "Text" - }, - { - "name": "chunk_size", - "ordinal": 6, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 3 - }, - "nullable": [false, true, false, false, true, false, true] - }, - "hash": "3dde3eaab357df88cd1c0e0e8e833aca1fce450c2d842a2af63f0e4c128424f7" -} diff --git a/opsqueue/.sqlx/query-3f33fea7cc44678f448d8cf3c0aeb59f155dd89f019f7c66c9609083f3a3dc6f.json b/opsqueue/.sqlx/query-3f33fea7cc44678f448d8cf3c0aeb59f155dd89f019f7c66c9609083f3a3dc6f.json deleted file mode 100644 index 67004d5..0000000 --- a/opsqueue/.sqlx/query-3f33fea7cc44678f448d8cf3c0aeb59f155dd89f019f7c66c9609083f3a3dc6f.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n INSERT INTO submissions (id, prefix, chunks_total, chunks_done, metadata, otel_trace_carrier, chunk_size)\n VALUES ($1, $2, $3, $4, $5, $6, $7)\n ", - "describe": { - "columns": [], - "parameters": { - "Right": 7 - }, - "nullable": [] - }, - "hash": "3f33fea7cc44678f448d8cf3c0aeb59f155dd89f019f7c66c9609083f3a3dc6f" -} diff --git a/opsqueue/.sqlx/query-40e96fd79c38c8338bcc2f18fbc43c8f71b1c6e73e73ce5f7687db469377c137.json b/opsqueue/.sqlx/query-40e96fd79c38c8338bcc2f18fbc43c8f71b1c6e73e73ce5f7687db469377c137.json deleted file mode 100644 index 1ce8f24..0000000 --- a/opsqueue/.sqlx/query-40e96fd79c38c8338bcc2f18fbc43c8f71b1c6e73e73ce5f7687db469377c137.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "UPDATE submissions SET chunks_done = chunks_done + 1 WHERE submissions.id = $1 RETURNING submissions.chunk_size;", - "describe": { - "columns": [ - { - "name": "chunk_size", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 1 - }, - "nullable": [true] - }, - "hash": "40e96fd79c38c8338bcc2f18fbc43c8f71b1c6e73e73ce5f7687db469377c137" -} diff --git a/opsqueue/.sqlx/query-47aa7f2a4838460952bb215bef9a036c487350a9886f9747ff0890849637070f.json b/opsqueue/.sqlx/query-47aa7f2a4838460952bb215bef9a036c487350a9886f9747ff0890849637070f.json deleted file mode 100644 index fe364ef..0000000 --- a/opsqueue/.sqlx/query-47aa7f2a4838460952bb215bef9a036c487350a9886f9747ff0890849637070f.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "DELETE FROM chunks_failed WHERE failed_at < julianday($1);", - "describe": { - "columns": [], - "parameters": { - "Right": 1 - }, - "nullable": [] - }, - "hash": "47aa7f2a4838460952bb215bef9a036c487350a9886f9747ff0890849637070f" -} diff --git a/opsqueue/.sqlx/query-5d1f0e786821af3135eb9022004308af3c683ba3cca9c97677072243289cb322.json b/opsqueue/.sqlx/query-5d1f0e786821af3135eb9022004308af3c683ba3cca9c97677072243289cb322.json deleted file mode 100644 index 0a4cd49..0000000 --- a/opsqueue/.sqlx/query-5d1f0e786821af3135eb9022004308af3c683ba3cca9c97677072243289cb322.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "SELECT COUNT(1) as count FROM chunks;", - "describe": { - "columns": [ - { - "name": "count", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [false] - }, - "hash": "5d1f0e786821af3135eb9022004308af3c683ba3cca9c97677072243289cb322" -} diff --git a/opsqueue/.sqlx/query-5f7d80f5b4990d9d4e0cca6491d7a34acf1328802fda82eb2281b59a792820de.json b/opsqueue/.sqlx/query-5f7d80f5b4990d9d4e0cca6491d7a34acf1328802fda82eb2281b59a792820de.json deleted file mode 100644 index 505b3bc..0000000 --- a/opsqueue/.sqlx/query-5f7d80f5b4990d9d4e0cca6491d7a34acf1328802fda82eb2281b59a792820de.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "SELECT COUNT(1) as count FROM submissions_failed;", - "describe": { - "columns": [ - { - "name": "count", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [false] - }, - "hash": "5f7d80f5b4990d9d4e0cca6491d7a34acf1328802fda82eb2281b59a792820de" -} diff --git a/opsqueue/.sqlx/query-62b1b5988a509f9722489522fbe3c650e1e04bcf51db8f97cbfb85a3e3d0c3bc.json b/opsqueue/.sqlx/query-62b1b5988a509f9722489522fbe3c650e1e04bcf51db8f97cbfb85a3e3d0c3bc.json deleted file mode 100644 index 55aa8c1..0000000 --- a/opsqueue/.sqlx/query-62b1b5988a509f9722489522fbe3c650e1e04bcf51db8f97cbfb85a3e3d0c3bc.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "SELECT COUNT(1) as count FROM submissions_completed;", - "describe": { - "columns": [ - { - "name": "count", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [false] - }, - "hash": "62b1b5988a509f9722489522fbe3c650e1e04bcf51db8f97cbfb85a3e3d0c3bc" -} diff --git a/opsqueue/.sqlx/query-643bc1f502a5c1cf79773ba3db2a7094263151c99f123eb5c2fa01c303b29730.json b/opsqueue/.sqlx/query-643bc1f502a5c1cf79773ba3db2a7094263151c99f123eb5c2fa01c303b29730.json deleted file mode 100644 index a3fe6ba..0000000 --- a/opsqueue/.sqlx/query-643bc1f502a5c1cf79773ba3db2a7094263151c99f123eb5c2fa01c303b29730.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n INSERT INTO submissions_metadata\n ( submission_id\n , metadata_key\n , metadata_value\n )\n VALUES ($1, $2, $3)\n ", - "describe": { - "columns": [], - "parameters": { - "Right": 3 - }, - "nullable": [] - }, - "hash": "643bc1f502a5c1cf79773ba3db2a7094263151c99f123eb5c2fa01c303b29730" -} diff --git a/opsqueue/.sqlx/query-6c3fac07b6b1b07ccdaaf0d296647176104b93c64a7a9fb85e2fd1e88ec13143.json b/opsqueue/.sqlx/query-6c3fac07b6b1b07ccdaaf0d296647176104b93c64a7a9fb85e2fd1e88ec13143.json deleted file mode 100644 index 8dd9d5e..0000000 --- a/opsqueue/.sqlx/query-6c3fac07b6b1b07ccdaaf0d296647176104b93c64a7a9fb85e2fd1e88ec13143.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "SELECT COUNT(1) as count FROM submissions;", - "describe": { - "columns": [ - { - "name": "count", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [false] - }, - "hash": "6c3fac07b6b1b07ccdaaf0d296647176104b93c64a7a9fb85e2fd1e88ec13143" -} diff --git a/opsqueue/.sqlx/query-833bc5d955f1c2455e06e9762dec84c4c24fe58c21165e6a80d0a5bfae1a3cd7.json b/opsqueue/.sqlx/query-833bc5d955f1c2455e06e9762dec84c4c24fe58c21165e6a80d0a5bfae1a3cd7.json deleted file mode 100644 index 257cff9..0000000 --- a/opsqueue/.sqlx/query-833bc5d955f1c2455e06e9762dec84c4c24fe58c21165e6a80d0a5bfae1a3cd7.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n UPDATE chunks SET retries = retries + 1\n WHERE submission_id = $1 AND chunk_index = $2\n RETURNING retries;\n ", - "describe": { - "columns": [ - { - "name": "retries", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 2 - }, - "nullable": [false] - }, - "hash": "833bc5d955f1c2455e06e9762dec84c4c24fe58c21165e6a80d0a5bfae1a3cd7" -} diff --git a/opsqueue/.sqlx/query-8b8e30b00dfb87367222b690744540438f1762a55694b429dfb4eeb15c230bd5.json b/opsqueue/.sqlx/query-8b8e30b00dfb87367222b690744540438f1762a55694b429dfb4eeb15c230bd5.json deleted file mode 100644 index 00bf073..0000000 --- a/opsqueue/.sqlx/query-8b8e30b00dfb87367222b690744540438f1762a55694b429dfb4eeb15c230bd5.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n INSERT INTO chunks_metadata\n ( submission_id\n , chunk_index\n , metadata_key\n , metadata_value\n )\n VALUES ($1, $2, $3, $4)\n ", - "describe": { - "columns": [], - "parameters": { - "Right": 4 - }, - "nullable": [] - }, - "hash": "8b8e30b00dfb87367222b690744540438f1762a55694b429dfb4eeb15c230bd5" -} diff --git a/opsqueue/.sqlx/query-91d3b5ff8e68c788d3209b4f1234a519eba5773d88c91635f5ffb01b1b5302fa.json b/opsqueue/.sqlx/query-91d3b5ff8e68c788d3209b4f1234a519eba5773d88c91635f5ffb01b1b5302fa.json deleted file mode 100644 index d74b332..0000000 --- a/opsqueue/.sqlx/query-91d3b5ff8e68c788d3209b4f1234a519eba5773d88c91635f5ffb01b1b5302fa.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "SELECT COALESCE(SUM(chunk_size * 1.0), 0.0) as count FROM chunks INNER JOIN submissions ON chunks.submission_id = submissions.id", - "describe": { - "columns": [ - { - "name": "count", - "ordinal": 0, - "type_info": "Float" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [false] - }, - "hash": "91d3b5ff8e68c788d3209b4f1234a519eba5773d88c91635f5ffb01b1b5302fa" -} diff --git a/opsqueue/.sqlx/query-a239d197e4047338a8b0a0549ce792a4326fb523efa9608b285795f9f026103a.json b/opsqueue/.sqlx/query-a239d197e4047338a8b0a0549ce792a4326fb523efa9608b285795f9f026103a.json deleted file mode 100644 index 713e6bf..0000000 --- a/opsqueue/.sqlx/query-a239d197e4047338a8b0a0549ce792a4326fb523efa9608b285795f9f026103a.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "DELETE FROM chunks_completed WHERE completed_at < julianday($1);", - "describe": { - "columns": [], - "parameters": { - "Right": 1 - }, - "nullable": [] - }, - "hash": "a239d197e4047338a8b0a0549ce792a4326fb523efa9608b285795f9f026103a" -} diff --git a/opsqueue/.sqlx/query-b7c7b04d131024ee962a37970a1dc12732c8b627522d508decaa1c164923075f.json b/opsqueue/.sqlx/query-b7c7b04d131024ee962a37970a1dc12732c8b627522d508decaa1c164923075f.json deleted file mode 100644 index 0fd668e..0000000 --- a/opsqueue/.sqlx/query-b7c7b04d131024ee962a37970a1dc12732c8b627522d508decaa1c164923075f.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "DELETE FROM submissions_failed WHERE failed_at < julianday($1);", - "describe": { - "columns": [], - "parameters": { - "Right": 1 - }, - "nullable": [] - }, - "hash": "b7c7b04d131024ee962a37970a1dc12732c8b627522d508decaa1c164923075f" -} diff --git a/opsqueue/.sqlx/query-c149e54e9a57cd5ded5e9e2656116ba9d04e56ffdbb41bb152ae5762475b5c78.json b/opsqueue/.sqlx/query-c149e54e9a57cd5ded5e9e2656116ba9d04e56ffdbb41bb152ae5762475b5c78.json deleted file mode 100644 index 1419ef9..0000000 --- a/opsqueue/.sqlx/query-c149e54e9a57cd5ded5e9e2656116ba9d04e56ffdbb41bb152ae5762475b5c78.json +++ /dev/null @@ -1,48 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT\n id AS \"id: SubmissionId\"\n , prefix\n , chunks_total AS \"chunks_total: ChunkCount\"\n , chunks_done AS \"chunks_done: ChunkCount\"\n , chunk_size AS \"chunk_size: ChunkSize\"\n , metadata\n , otel_trace_carrier\n FROM submissions WHERE id = $1\n ", - "describe": { - "columns": [ - { - "name": "id: SubmissionId", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "prefix", - "ordinal": 1, - "type_info": "Text" - }, - { - "name": "chunks_total: ChunkCount", - "ordinal": 2, - "type_info": "Integer" - }, - { - "name": "chunks_done: ChunkCount", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "chunk_size: ChunkSize", - "ordinal": 4, - "type_info": "Integer" - }, - { - "name": "metadata", - "ordinal": 5, - "type_info": "Blob" - }, - { - "name": "otel_trace_carrier", - "ordinal": 6, - "type_info": "Text" - } - ], - "parameters": { - "Right": 1 - }, - "nullable": [false, true, false, false, true, true, false] - }, - "hash": "c149e54e9a57cd5ded5e9e2656116ba9d04e56ffdbb41bb152ae5762475b5c78" -} diff --git a/opsqueue/.sqlx/query-c4fc111b75ae4036c16042be654600dd598dddd4ee9412522b22127e5bceedc1.json b/opsqueue/.sqlx/query-c4fc111b75ae4036c16042be654600dd598dddd4ee9412522b22127e5bceedc1.json deleted file mode 100644 index 12d8ee5..0000000 --- a/opsqueue/.sqlx/query-c4fc111b75ae4036c16042be654600dd598dddd4ee9412522b22127e5bceedc1.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n INSERT INTO chunks_completed\n (submission_id, chunk_index, output_content, completed_at)\n SELECT submission_id, chunk_index, $1, julianday($2) FROM chunks\n WHERE chunks.submission_id = $3 AND chunks.chunk_index = $4;\n\n DELETE FROM chunks WHERE chunks.submission_id = $5 AND chunks.chunk_index = $6\n RETURNING submission_id, chunk_index;\n ", - "describe": { - "columns": [ - { - "name": "submission_id", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "chunk_index", - "ordinal": 1, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 6 - }, - "nullable": [false, false] - }, - "hash": "c4fc111b75ae4036c16042be654600dd598dddd4ee9412522b22127e5bceedc1" -} diff --git a/opsqueue/.sqlx/query-c63e36ec8d3675dd160e289451f181cff1c82b07427f0b4d4b45132a9d3dcc6d.json b/opsqueue/.sqlx/query-c63e36ec8d3675dd160e289451f181cff1c82b07427f0b4d4b45132a9d3dcc6d.json deleted file mode 100644 index 746a3b4..0000000 --- a/opsqueue/.sqlx/query-c63e36ec8d3675dd160e289451f181cff1c82b07427f0b4d4b45132a9d3dcc6d.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SAVEPOINT skip_remaining_chunks;\n\n INSERT INTO chunks_failed\n (submission_id, chunk_index, input_content, failure, skipped, failed_at)\n SELECT submission_id, chunk_index, input_content, '', 1, julianday($1) FROM chunks WHERE chunks.submission_id = $2;\n\n DELETE FROM chunks WHERE chunks.submission_id = $3;\n\n RELEASE SAVEPOINT skip_remaining_chunks;\n ", - "describe": { - "columns": [], - "parameters": { - "Right": 3 - }, - "nullable": [] - }, - "hash": "c63e36ec8d3675dd160e289451f181cff1c82b07427f0b4d4b45132a9d3dcc6d" -} diff --git a/opsqueue/.sqlx/query-c7d9c26e33f222d9b685d3a74a69c3cdd4bce3f9c4fc19e518b1d48930ba793d.json b/opsqueue/.sqlx/query-c7d9c26e33f222d9b685d3a74a69c3cdd4bce3f9c4fc19e518b1d48930ba793d.json deleted file mode 100644 index 4373470..0000000 --- a/opsqueue/.sqlx/query-c7d9c26e33f222d9b685d3a74a69c3cdd4bce3f9c4fc19e518b1d48930ba793d.json +++ /dev/null @@ -1,53 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT\n id AS \"id: SubmissionId\"\n , prefix\n , chunks_total AS \"chunks_total: ChunkCount\"\n , chunk_size AS \"chunk_size: ChunkSize\"\n , metadata\n , failed_at AS \"failed_at: DateTime\"\n , failed_chunk_id AS \"failed_chunk_id: ChunkIndex\"\n , otel_trace_carrier\n FROM submissions_failed WHERE id = $1\n ", - "describe": { - "columns": [ - { - "name": "id: SubmissionId", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "prefix", - "ordinal": 1, - "type_info": "Text" - }, - { - "name": "chunks_total: ChunkCount", - "ordinal": 2, - "type_info": "Integer" - }, - { - "name": "chunk_size: ChunkSize", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "metadata", - "ordinal": 4, - "type_info": "Blob" - }, - { - "name": "failed_at: DateTime", - "ordinal": 5, - "type_info": "Datetime" - }, - { - "name": "failed_chunk_id: ChunkIndex", - "ordinal": 6, - "type_info": "Integer" - }, - { - "name": "otel_trace_carrier", - "ordinal": 7, - "type_info": "Text" - } - ], - "parameters": { - "Right": 1 - }, - "nullable": [false, true, false, true, true, false, false, false] - }, - "hash": "c7d9c26e33f222d9b685d3a74a69c3cdd4bce3f9c4fc19e518b1d48930ba793d" -} diff --git a/opsqueue/.sqlx/query-d41c3708cdd638119649b290f4a22300280f308ab8712ac5a44efd17e4680c43.json b/opsqueue/.sqlx/query-d41c3708cdd638119649b290f4a22300280f308ab8712ac5a44efd17e4680c43.json deleted file mode 100644 index 4614a39..0000000 --- a/opsqueue/.sqlx/query-d41c3708cdd638119649b290f4a22300280f308ab8712ac5a44efd17e4680c43.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "db_name": "SQLite", - "query": "INSERT INTO chunks (submission_id, chunk_index, input_content) VALUES ($1, $2, $3)", - "describe": { - "columns": [], - "parameters": { - "Right": 3 - }, - "nullable": [] - }, - "hash": "d41c3708cdd638119649b290f4a22300280f308ab8712ac5a44efd17e4680c43" -} diff --git a/opsqueue/.sqlx/query-d5aa781509794455e2e8e16b2ba1485efd45597a65e4bb7ae8d2888112b3a272.json b/opsqueue/.sqlx/query-d5aa781509794455e2e8e16b2ba1485efd45597a65e4bb7ae8d2888112b3a272.json deleted file mode 100644 index 2aa293e..0000000 --- a/opsqueue/.sqlx/query-d5aa781509794455e2e8e16b2ba1485efd45597a65e4bb7ae8d2888112b3a272.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "SELECT COUNT(1) as count FROM chunks_completed;", - "describe": { - "columns": [ - { - "name": "count", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [false] - }, - "hash": "d5aa781509794455e2e8e16b2ba1485efd45597a65e4bb7ae8d2888112b3a272" -} diff --git a/opsqueue/.sqlx/query-e282079ded2d608817a2b2d27917f097eb0ec213e5a9a4027563c44f4a05bca3.json b/opsqueue/.sqlx/query-e282079ded2d608817a2b2d27917f097eb0ec213e5a9a4027563c44f4a05bca3.json deleted file mode 100644 index 81d6fa0..0000000 --- a/opsqueue/.sqlx/query-e282079ded2d608817a2b2d27917f097eb0ec213e5a9a4027563c44f4a05bca3.json +++ /dev/null @@ -1,38 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT\n submission_id AS \"submission_id: SubmissionId\"\n , chunk_index AS \"chunk_index: ChunkIndex\"\n , input_content\n , failure AS \"failure: String\"\n , failed_at AS \"failed_at: DateTime\"\n FROM chunks_failed WHERE submission_id = $1 AND chunk_index = $2\n ", - "describe": { - "columns": [ - { - "name": "submission_id: SubmissionId", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "chunk_index: ChunkIndex", - "ordinal": 1, - "type_info": "Integer" - }, - { - "name": "input_content", - "ordinal": 2, - "type_info": "Blob" - }, - { - "name": "failure: String", - "ordinal": 3, - "type_info": "Blob" - }, - { - "name": "failed_at: DateTime", - "ordinal": 4, - "type_info": "Datetime" - } - ], - "parameters": { - "Right": 2 - }, - "nullable": [false, false, true, false, false] - }, - "hash": "e282079ded2d608817a2b2d27917f097eb0ec213e5a9a4027563c44f4a05bca3" -} diff --git a/opsqueue/.sqlx/query-e73afd2c8d84e6c3044f0662525f97bc8ca1d36a9305fdb959ef0e577846d606.json b/opsqueue/.sqlx/query-e73afd2c8d84e6c3044f0662525f97bc8ca1d36a9305fdb959ef0e577846d606.json deleted file mode 100644 index 50317dd..0000000 --- a/opsqueue/.sqlx/query-e73afd2c8d84e6c3044f0662525f97bc8ca1d36a9305fdb959ef0e577846d606.json +++ /dev/null @@ -1,18 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT id AS \"id: SubmissionId\" FROM submissions WHERE prefix = $1\n UNION ALL\n SELECT id AS \"id: SubmissionId\" FROM submissions_completed WHERE prefix = $2\n UNION ALL\n SELECT id AS \"id: SubmissionId\" FROM submissions_failed WHERE prefix = $3\n ", - "describe": { - "columns": [ - { - "name": "id: SubmissionId", - "ordinal": 0, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 3 - }, - "nullable": [false] - }, - "hash": "e73afd2c8d84e6c3044f0662525f97bc8ca1d36a9305fdb959ef0e577846d606" -} diff --git a/opsqueue/.sqlx/query-e92c5478fe8f1e5dee3d5e73ecf4cb3f2b7e422cefb1ecc00cf17299edec83c8.json b/opsqueue/.sqlx/query-e92c5478fe8f1e5dee3d5e73ecf4cb3f2b7e422cefb1ecc00cf17299edec83c8.json deleted file mode 100644 index 9b017ac..0000000 --- a/opsqueue/.sqlx/query-e92c5478fe8f1e5dee3d5e73ecf4cb3f2b7e422cefb1ecc00cf17299edec83c8.json +++ /dev/null @@ -1,38 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SAVEPOINT move_chunk_to_failed_chunks;\n\n INSERT INTO chunks_failed\n (submission_id, chunk_index, input_content, failure, failed_at)\n SELECT submission_id, chunk_index, input_content, $1, julianday($2) FROM chunks WHERE chunks.submission_id = $3 AND chunks.chunk_index = $4;\n\n DELETE FROM chunks WHERE chunks.submission_id = $5 AND chunks.chunk_index = $6 RETURNING *;\n\n RELEASE SAVEPOINT move_chunk_to_failed_chunks;\n ", - "describe": { - "columns": [ - { - "name": "submission_id", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "chunk_index", - "ordinal": 1, - "type_info": "Integer" - }, - { - "name": "input_content", - "ordinal": 2, - "type_info": "Blob" - }, - { - "name": "retries", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "random_order", - "ordinal": 4, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 6 - }, - "nullable": [false, false, true, false, false] - }, - "hash": "e92c5478fe8f1e5dee3d5e73ecf4cb3f2b7e422cefb1ecc00cf17299edec83c8" -} diff --git a/opsqueue/.sqlx/query-eda8781445cef23e17446ca9007955f377d4059478a2bda4e5bd39ecd836e838.json b/opsqueue/.sqlx/query-eda8781445cef23e17446ca9007955f377d4059478a2bda4e5bd39ecd836e838.json deleted file mode 100644 index a3e64a8..0000000 --- a/opsqueue/.sqlx/query-eda8781445cef23e17446ca9007955f377d4059478a2bda4e5bd39ecd836e838.json +++ /dev/null @@ -1,23 +0,0 @@ -{ - "db_name": "SQLite", - "query": "\n SELECT metadata_key, metadata_value FROM submissions_metadata\n WHERE submission_id = $1\n ", - "describe": { - "columns": [ - { - "name": "metadata_key", - "ordinal": 0, - "type_info": "Text" - }, - { - "name": "metadata_value", - "ordinal": 1, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 1 - }, - "nullable": [false, false] - }, - "hash": "eda8781445cef23e17446ca9007955f377d4059478a2bda4e5bd39ecd836e838" -} diff --git a/opsqueue/.sqlx/query-ef677e899bf812760d0d24c9fa1fb791a5585629b14baab7a35185469c2e2e85.json b/opsqueue/.sqlx/query-ef677e899bf812760d0d24c9fa1fb791a5585629b14baab7a35185469c2e2e85.json deleted file mode 100644 index 4d82179..0000000 --- a/opsqueue/.sqlx/query-ef677e899bf812760d0d24c9fa1fb791a5585629b14baab7a35185469c2e2e85.json +++ /dev/null @@ -1,38 +0,0 @@ -{ - "db_name": "SQLite", - "query": "SELECT * FROM chunks_metadata;", - "describe": { - "columns": [ - { - "name": "submission_id", - "ordinal": 0, - "type_info": "Integer" - }, - { - "name": "chunk_index", - "ordinal": 1, - "type_info": "Integer" - }, - { - "name": "metadata_key", - "ordinal": 2, - "type_info": "Text" - }, - { - "name": "metadata_value", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "random_order", - "ordinal": 4, - "type_info": "Integer" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [false, false, false, false, true] - }, - "hash": "ef677e899bf812760d0d24c9fa1fb791a5585629b14baab7a35185469c2e2e85" -} diff --git a/opsqueue/Cargo.toml b/opsqueue/Cargo.toml index dd23ab1..d4f3e5e 100644 --- a/opsqueue/Cargo.toml +++ b/opsqueue/Cargo.toml @@ -5,7 +5,6 @@ edition = "2021" description = "lightweight batch processing queue for heavy loads" repository = "https://github.com/channable/opsqueue" license = "MIT" -include=["opsqueue_example_database_schema.db"] [lib] name="opsqueue"