diff --git a/apps/backend/src/repositories/worker-platform/work-order-query-repo.ts b/apps/backend/src/repositories/worker-platform/work-order-query-repo.ts index 3825c862..03510641 100644 --- a/apps/backend/src/repositories/worker-platform/work-order-query-repo.ts +++ b/apps/backend/src/repositories/worker-platform/work-order-query-repo.ts @@ -1123,25 +1123,25 @@ export function buildWorkOrderWhere({ INNER JOIN ( SELECT assigned.id AS work_order_id FROM work_orders assigned - WHERE assigned.assigned_worker_id = ${workerSharePlaceholder} + WHERE assigned.assigned_worker_id = ${workerSharePlaceholder}::bigint UNION SELECT historical.id AS work_order_id FROM work_orders historical - WHERE ${retainedWorkerOrderPredicate('historical', workerSharePlaceholder)} + WHERE ${retainedWorkerOrderPredicate('historical', `${workerSharePlaceholder}::bigint`)} UNION SELECT share_source.work_order_id FROM work_order_shares share_source - WHERE share_source.worker_id = ${workerSharePlaceholder} + WHERE share_source.worker_id = ${workerSharePlaceholder}::bigint AND share_source.status != 'cancelled' UNION SELECT timeout_ev.work_order_id FROM work_order_events timeout_ev WHERE timeout_ev.event_type LIKE 'timeout_%' - AND timeout_ev.payload_json->>'workerId' = ${workerSharePlaceholder} + AND timeout_ev.payload_json->>'workerId' = ${workerSharePlaceholder}::text ) worker_visible ON worker_visible.work_order_id = wo.id LEFT JOIN work_order_shares worker_share ON worker_share.work_order_id = wo.id - AND worker_share.worker_id = ${workerSharePlaceholder}`) + AND worker_share.worker_id = ${workerSharePlaceholder}::bigint`) } if (useOperationalStatus) {