INFO     src.framework.common.api:api.py:97 {"timestamp": "2026-04-04T23:50:51.093084", "type": "request", "method": "POST", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/oauth/custom/token", "headers": {"x-aer-mock-hub": "true", "x-aer-mock-lp": "true", "x-aer-mock-ff": "true", "x-aer-mock-yandex-bond": "true", "x-aer-mock-egov-uz": "true", "x-aer-mock-tmg": "true", "x-aer-mesh": "dm-hub-service-package:master;dm-hub-service-package-external:master;dm-hub-service-sorting:master;dm-hub-service-asn:master;dm-hub-service-inbound:master;dm-hub-service-meta:master;dm-hub-service-configuration:master;dm-hub-service-packing:master;dm-hub-service-dispatch:master;dm-hub-service-label:master;dm-hub-service-storage:master;dm-hub-service-cargo:master;dm-hub-service-country:master;dm-hub-service-customs:master;dm-hub-service-document:master;dm-hub-service-email:master;dm-hub-service-file-storage:master;dm-hub-service-inspection:master;dm-hub-service-osl:master;dm-hub-service-partners:master;dm-hub-service-report:master;dm-hub-service-settings:master;dm-hub-service-short-link:master;dm-hub-service-templates:master;dm-hub-service-tracking:master;dm-hub-service-transliteration:master;dm-hub-service-processing:master;dm-hub-api-cargo-carrier:master;dm-hub-api-fe:master;dm-hub-api-ff:master;dm-hub-api-wms:master;dm-hub-api-aer:master;dm-hub-api-joom:master;dm-hub-api-gateway:master;dm-hub-api-partners:master;dm-hub-api-pochta-global:master;dm-hub-api-public:master;dm-hub-api-wildberries:master;dm-hub-api-internal:master;dm-hub-daemon-package-process:master;dm-hub-daemon-tracking:master;dm-hub-integration-ff:master;dm-hub-integration-aer:master;dm-hub-integration-cainiao:master;dm-hub-integration-cargo-carrier:master;dm-hub-integration-gtt:master;dm-hub-integration-kazpost:master;dm-hub-integration-kgpost:master;dm-hub-integration-partners:master;dm-hub-integration-post:master;dm-hub-integration-rupost:master;dm-hub-integration-telegram:master;dm-hub-integration-upu:master;dm-hub-integration-wms:master;dm-hub-workflow-asn:master;dm-hub-workflow-email:master;dm-hub-workflow-hub-external:master;dm-hub-workflow-hub-internal:master;dm-hub-workflow-integration:master;dm-hub-workflow-package:master;dm-hub-workflow-tracking:master;dm-hub-workflow-hub-internal:master;dm-hub-service-packing:master;dm-hub-service-cargo:master;dm-hub-workflow-hub-external:master"}, "json": {"login": "9000000001", "password": "1234", "grantType": "password"}, "timeout": 30}
INFO     src.framework.common.api:api.py:121 {"timestamp": "2026-04-04T23:50:51.128099", "type": "response", "method": "POST", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/oauth/custom/token", "status_code": 200, "trace_id": "5237c4e137b4ccc2421e3e13f4e166fb", "headers": {}, "body": "{\"token\":\"0ae2e3d0-640e-443c-bc10-88a48455a831\",\"expired\":false,\"refreshToken\":\"411207b1-1c97-40f2-b1c2-418dac163f36\",\"expiresIn\":232021,\"expiration\":\"2026-04-07T16:17:52.126+00:00\"}", "elapsed_time": 0.033789, "reason": "OK"}
INFO     sqlalchemy.engine.Engine:base.py:2710 BEGIN (implicit; DBAPI should not BEGIN due to autocommit mode)
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT cell.id, cell.zone_id, cell.cell_barcode, cell.is_active, cell.type, cell.create_at, cell.update_at 
FROM cell 
WHERE cell.zone_id = %(zone_id_1)s AND cell.type = %(type_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 568.8s ago] {'zone_id_1': 5, 'type_1': <StockCellType.STORAGE: 'STORAGE'>}
INFO     kafka.conn:conn.py:400 <BrokerConnection client_id=kafka-python-producer-15, node_id=bootstrap-0 host=redpanda.redpanda-operator.svc:9092 <connecting> [IPv4 ('10.100.48.16', 9092)]>: connecting to redpanda.redpanda-operator.svc:9092 [('10.100.48.16', 9092) IPv4]
INFO     kafka.conn:conn.py:622 <BrokerConnection client_id=kafka-python-producer-15, node_id=bootstrap-0 host=redpanda.redpanda-operator.svc:9092 <checking_api_versions_recv> [IPv4 ('10.100.48.16', 9092)]>: Broker version identified as 2.6
INFO     kafka.conn:conn.py:461 <BrokerConnection client_id=kafka-python-producer-15, node_id=bootstrap-0 host=redpanda.redpanda-operator.svc:9092 <connected> [IPv4 ('10.100.48.16', 9092)]>: Connection complete.
INFO     kafka.conn:conn.py:400 <BrokerConnection client_id=kafka-python-producer-15, node_id=0 host=redpanda-0.redpanda.redpanda-operator.svc.cluster.local.:9092 <connecting> [IPv4 ('10.100.174.181', 9092)]>: connecting to redpanda-0.redpanda.redpanda-operator.svc.cluster.local.:9092 [('10.100.174.181', 9092) IPv4]
INFO     kafka.conn:conn.py:461 <BrokerConnection client_id=kafka-python-producer-15, node_id=0 host=redpanda-0.redpanda.redpanda-operator.svc.cluster.local.:9092 <connected> [IPv4 ('10.100.174.181', 9092)]>: Connection complete.
INFO     kafka.conn:conn.py:951 <BrokerConnection client_id=kafka-python-producer-15, node_id=bootstrap-0 host=redpanda.redpanda-operator.svc:9092 <connected> [IPv4 ('10.100.48.16', 9092)]>: Closing connection. 
INFO     kafka.conn:conn.py:400 <BrokerConnection client_id=kafka-python-producer-15, node_id=1 host=redpanda-1.redpanda.redpanda-operator.svc.cluster.local.:9092 <connecting> [IPv4 ('10.100.48.16', 9092)]>: connecting to redpanda-1.redpanda.redpanda-operator.svc.cluster.local.:9092 [('10.100.48.16', 9092) IPv4]
INFO     kafka.conn:conn.py:461 <BrokerConnection client_id=kafka-python-producer-15, node_id=1 host=redpanda-1.redpanda.redpanda-operator.svc.cluster.local.:9092 <connected> [IPv4 ('10.100.48.16', 9092)]>: Connection complete.
INFO     kafka.conn:conn.py:951 <BrokerConnection client_id=kafka-python-producer-15, node_id=0 host=redpanda-0.redpanda.redpanda-operator.svc.cluster.local.:9092 <connected> [IPv4 ('10.100.174.181', 9092)]>: Closing connection. 
INFO     kafka.conn:conn.py:951 <BrokerConnection client_id=kafka-python-producer-15, node_id=1 host=redpanda-1.redpanda.redpanda-operator.svc.cluster.local.:9092 <connected> [IPv4 ('10.100.48.16', 9092)]>: Closing connection. 
INFO     sqlalchemy.engine.Engine:base.py:2710 BEGIN (implicit; DBAPI should not BEGIN due to autocommit mode)
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT inbox.id, inbox.topic, inbox.payload, inbox.status, inbox.retry_count, inbox.max_retry_count, inbox.key, inbox.headers, inbox.created_at, inbox.next_retry_at, inbox.processing_started_at, inbox.error_message, inbox.exception_stack_trace, inbox.processing_node, inbox.processing_timeout_minutes 
FROM inbox 
WHERE inbox.topic = %(topic_1)s AND CAST(inbox.payload AS VARCHAR) LIKE %(param_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 670s ago] {'topic_1': <KafkaTopics.fmcg_invoice_create: 'fmcg_invoice_create'>, 'param_1': '%75346651129259520%'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT inbox.id, inbox.topic, inbox.payload, inbox.status, inbox.retry_count, inbox.max_retry_count, inbox.key, inbox.headers, inbox.created_at, inbox.next_retry_at, inbox.processing_started_at, inbox.error_message, inbox.exception_stack_trace, inbox.processing_node, inbox.processing_timeout_minutes 
FROM inbox 
WHERE inbox.topic = %(topic_1)s AND CAST(inbox.payload AS VARCHAR) LIKE %(param_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 675s ago] {'topic_1': <KafkaTopics.fmcg_invoice_create: 'fmcg_invoice_create'>, 'param_1': '%75346651129259520%'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT invoice.id, invoice.lk_invoice_id, invoice.original_invoice_number, invoice.need_mark, invoice.has_expiration_date, invoice.is_declared, invoice.invoice_status, invoice.date_create, invoice.vehicle_id, invoice.is_test, invoice.date_arrival, invoice.seller_id, invoice.warehouse_id, invoice.gtd_number, invoice.date_update, invoice.date_finished, invoice.partner_id 
FROM invoice 
WHERE invoice.original_invoice_number = %(original_invoice_number_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 660s ago] {'original_invoice_number_1': '75346651129259520'}
INFO     kafka.conn:conn.py:400 <BrokerConnection client_id=kafka-python-producer-16, node_id=bootstrap-0 host=redpanda.redpanda-operator.svc:9092 <connecting> [IPv4 ('10.100.174.181', 9092)]>: connecting to redpanda.redpanda-operator.svc:9092 [('10.100.174.181', 9092) IPv4]
INFO     kafka.conn:conn.py:622 <BrokerConnection client_id=kafka-python-producer-16, node_id=bootstrap-0 host=redpanda.redpanda-operator.svc:9092 <checking_api_versions_recv> [IPv4 ('10.100.174.181', 9092)]>: Broker version identified as 2.6
INFO     kafka.conn:conn.py:461 <BrokerConnection client_id=kafka-python-producer-16, node_id=bootstrap-0 host=redpanda.redpanda-operator.svc:9092 <connected> [IPv4 ('10.100.174.181', 9092)]>: Connection complete.
INFO     kafka.conn:conn.py:400 <BrokerConnection client_id=kafka-python-producer-16, node_id=1 host=redpanda-1.redpanda.redpanda-operator.svc.cluster.local.:9092 <connecting> [IPv4 ('10.100.48.16', 9092)]>: connecting to redpanda-1.redpanda.redpanda-operator.svc.cluster.local.:9092 [('10.100.48.16', 9092) IPv4]
INFO     kafka.conn:conn.py:461 <BrokerConnection client_id=kafka-python-producer-16, node_id=1 host=redpanda-1.redpanda.redpanda-operator.svc.cluster.local.:9092 <connected> [IPv4 ('10.100.48.16', 9092)]>: Connection complete.
INFO     kafka.conn:conn.py:951 <BrokerConnection client_id=kafka-python-producer-16, node_id=bootstrap-0 host=redpanda.redpanda-operator.svc:9092 <connected> [IPv4 ('10.100.174.181', 9092)]>: Closing connection. 
INFO     kafka.conn:conn.py:400 <BrokerConnection client_id=kafka-python-producer-16, node_id=0 host=redpanda-0.redpanda.redpanda-operator.svc.cluster.local.:9092 <connecting> [IPv4 ('10.100.174.181', 9092)]>: connecting to redpanda-0.redpanda.redpanda-operator.svc.cluster.local.:9092 [('10.100.174.181', 9092) IPv4]
INFO     kafka.conn:conn.py:461 <BrokerConnection client_id=kafka-python-producer-16, node_id=0 host=redpanda-0.redpanda.redpanda-operator.svc.cluster.local.:9092 <connected> [IPv4 ('10.100.174.181', 9092)]>: Connection complete.
INFO     kafka.conn:conn.py:951 <BrokerConnection client_id=kafka-python-producer-16, node_id=1 host=redpanda-1.redpanda.redpanda-operator.svc.cluster.local.:9092 <connected> [IPv4 ('10.100.48.16', 9092)]>: Closing connection. 
INFO     kafka.conn:conn.py:951 <BrokerConnection client_id=kafka-python-producer-16, node_id=0 host=redpanda-0.redpanda.redpanda-operator.svc.cluster.local.:9092 <connected> [IPv4 ('10.100.174.181', 9092)]>: Closing connection. 
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT inbox.id, inbox.topic, inbox.payload, inbox.status, inbox.retry_count, inbox.max_retry_count, inbox.key, inbox.headers, inbox.created_at, inbox.next_retry_at, inbox.processing_started_at, inbox.error_message, inbox.exception_stack_trace, inbox.processing_node, inbox.processing_timeout_minutes 
FROM inbox 
WHERE inbox.topic = %(topic_1)s AND CAST(inbox.payload AS VARCHAR) LIKE %(param_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 675.1s ago] {'topic_1': <KafkaTopics.fmcg_invoice_items_create: 'fmcg_invoice_items_create'>, 'param_1': '%46954996485768%'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT inbox.id, inbox.topic, inbox.payload, inbox.status, inbox.retry_count, inbox.max_retry_count, inbox.key, inbox.headers, inbox.created_at, inbox.next_retry_at, inbox.processing_started_at, inbox.error_message, inbox.exception_stack_trace, inbox.processing_node, inbox.processing_timeout_minutes 
FROM inbox 
WHERE inbox.topic = %(topic_1)s AND CAST(inbox.payload AS VARCHAR) LIKE %(param_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 680.1s ago] {'topic_1': <KafkaTopics.fmcg_invoice_items_create: 'fmcg_invoice_items_create'>, 'param_1': '%46954996485768%'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT inbox.id, inbox.topic, inbox.payload, inbox.status, inbox.retry_count, inbox.max_retry_count, inbox.key, inbox.headers, inbox.created_at, inbox.next_retry_at, inbox.processing_started_at, inbox.error_message, inbox.exception_stack_trace, inbox.processing_node, inbox.processing_timeout_minutes 
FROM inbox 
WHERE inbox.topic = %(topic_1)s AND CAST(inbox.payload AS VARCHAR) LIKE %(param_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 685.1s ago] {'topic_1': <KafkaTopics.fmcg_invoice_items_create: 'fmcg_invoice_items_create'>, 'param_1': '%46954996485768%'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT inbox.id, inbox.topic, inbox.payload, inbox.status, inbox.retry_count, inbox.max_retry_count, inbox.key, inbox.headers, inbox.created_at, inbox.next_retry_at, inbox.processing_started_at, inbox.error_message, inbox.exception_stack_trace, inbox.processing_node, inbox.processing_timeout_minutes 
FROM inbox 
WHERE inbox.topic = %(topic_1)s AND CAST(inbox.payload AS VARCHAR) LIKE %(param_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 690.2s ago] {'topic_1': <KafkaTopics.fmcg_invoice_items_create: 'fmcg_invoice_items_create'>, 'param_1': '%46954996485768%'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT sku_lk.id, sku_lk.sku_id, sku_lk.name, sku_lk.has_mark, sku_lk.has_expiration_date, sku_lk.created_at, sku_lk.updated_at, sku_lk.external_sku_id, sku_lk.weight, sku_lk.height, sku_lk.length, sku_lk.width, sku_lk.image_url, sku_lk.seller_id, sku_lk.erp_id, barcode_info.id AS id_1, barcode_info.sku_lk_id, barcode_info.barcode, barcode_info.created_at AS created_at_1, barcode_info.updated_at AS updated_at_1, sku_bundle_lk.id AS id_2, sku_bundle_lk.sku_lk_id AS sku_lk_id_1, sku_bundle_lk.barcode AS barcode_1, sku_bundle_lk.item_amount, sku_bundle_lk.price, sku_bundle_lk.currency, sku_bundle_lk.weight AS weight_1, sku_bundle_lk.height AS height_1, sku_bundle_lk.length AS length_1, sku_bundle_lk.width AS width_1, sku_bundle_lk.created_at AS created_at_2, sku_bundle_lk.updated_at AS updated_at_2, sku_bundle_lk.number_bundle_on_level_pallet, sku_bundle_lk.external_sku_id AS external_sku_id_1, sku_bundle_lk.name AS name_1, sku_bundle_lk.erp_id AS erp_id_1 
FROM sku_lk LEFT OUTER JOIN barcode_info ON barcode_info.sku_lk_id = sku_lk.id LEFT OUTER JOIN sku_bundle_lk ON sku_bundle_lk.sku_lk_id = sku_lk.id 
WHERE sku_lk.sku_id = %(sku_id_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 665s ago] {'sku_id_1': 75346656267656192}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT barcode_info.id AS barcode_info_id, barcode_info.sku_lk_id AS barcode_info_sku_lk_id, barcode_info.barcode AS barcode_info_barcode, barcode_info.created_at AS barcode_info_created_at, barcode_info.updated_at AS barcode_info_updated_at 
FROM barcode_info 
WHERE %(param_1)s = barcode_info.sku_lk_id
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 665s ago] {'param_1': 3719}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT sku_bundle_lk.id AS sku_bundle_lk_id, sku_bundle_lk.sku_lk_id AS sku_bundle_lk_sku_lk_id, sku_bundle_lk.barcode AS sku_bundle_lk_barcode, sku_bundle_lk.item_amount AS sku_bundle_lk_item_amount, sku_bundle_lk.price AS sku_bundle_lk_price, sku_bundle_lk.currency AS sku_bundle_lk_currency, sku_bundle_lk.weight AS sku_bundle_lk_weight, sku_bundle_lk.height AS sku_bundle_lk_height, sku_bundle_lk.length AS sku_bundle_lk_length, sku_bundle_lk.width AS sku_bundle_lk_width, sku_bundle_lk.created_at AS sku_bundle_lk_created_at, sku_bundle_lk.updated_at AS sku_bundle_lk_updated_at, sku_bundle_lk.number_bundle_on_level_pallet AS sku_bundle_lk_number_bundle_on_level_pallet, sku_bundle_lk.external_sku_id AS sku_bundle_lk_external_sku_id, sku_bundle_lk.name AS sku_bundle_lk_name, sku_bundle_lk.erp_id AS sku_bundle_lk_erp_id 
FROM sku_bundle_lk 
WHERE %(param_1)s = sku_bundle_lk.sku_lk_id
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 665s ago] {'param_1': 3719}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT invoice.id, invoice.lk_invoice_id, invoice.original_invoice_number, invoice.need_mark, invoice.has_expiration_date, invoice.is_declared, invoice.invoice_status, invoice.date_create, invoice.vehicle_id, invoice.is_test, invoice.date_arrival, invoice.seller_id, invoice.warehouse_id, invoice.gtd_number, invoice.date_update, invoice.date_finished, invoice.partner_id 
FROM invoice 
WHERE invoice.original_invoice_number = %(original_invoice_number_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 675.2s ago] {'original_invoice_number_1': '75346651129259520'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT invoice.id, invoice.lk_invoice_id, invoice.original_invoice_number, invoice.need_mark, invoice.has_expiration_date, invoice.is_declared, invoice.invoice_status, invoice.date_create, invoice.vehicle_id, invoice.is_test, invoice.date_arrival, invoice.seller_id, invoice.warehouse_id, invoice.gtd_number, invoice.date_update, invoice.date_finished, invoice.partner_id 
FROM invoice 
WHERE invoice.original_invoice_number = %(original_invoice_number_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 675.2s ago] {'original_invoice_number_1': '75346651129259520'}
INFO     src.framework.common.api:api.py:97 {"timestamp": "2026-04-04T23:51:11.430105", "type": "request", "method": "POST", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/acceptance/invoices", "headers": {"x-aer-mock-hub": "true", "x-aer-mock-lp": "true", "x-aer-mock-ff": "true", "x-aer-mock-yandex-bond": "true", "x-aer-mock-egov-uz": "true", "x-aer-mock-tmg": "true", "x-aer-mesh": "dm-hub-service-package:master;dm-hub-service-package-external:master;dm-hub-service-sorting:master;dm-hub-service-asn:master;dm-hub-service-inbound:master;dm-hub-service-meta:master;dm-hub-service-configuration:master;dm-hub-service-packing:master;dm-hub-service-dispatch:master;dm-hub-service-label:master;dm-hub-service-storage:master;dm-hub-service-cargo:master;dm-hub-service-country:master;dm-hub-service-customs:master;dm-hub-service-document:master;dm-hub-service-email:master;dm-hub-service-file-storage:master;dm-hub-service-inspection:master;dm-hub-service-osl:master;dm-hub-service-partners:master;dm-hub-service-report:master;dm-hub-service-settings:master;dm-hub-service-short-link:master;dm-hub-service-templates:master;dm-hub-service-tracking:master;dm-hub-service-transliteration:master;dm-hub-service-processing:master;dm-hub-api-cargo-carrier:master;dm-hub-api-fe:master;dm-hub-api-ff:master;dm-hub-api-wms:master;dm-hub-api-aer:master;dm-hub-api-joom:master;dm-hub-api-gateway:master;dm-hub-api-partners:master;dm-hub-api-pochta-global:master;dm-hub-api-public:master;dm-hub-api-wildberries:master;dm-hub-api-internal:master;dm-hub-daemon-package-process:master;dm-hub-daemon-tracking:master;dm-hub-integration-ff:master;dm-hub-integration-aer:master;dm-hub-integration-cainiao:master;dm-hub-integration-cargo-carrier:master;dm-hub-integration-gtt:master;dm-hub-integration-kazpost:master;dm-hub-integration-kgpost:master;dm-hub-integration-partners:master;dm-hub-integration-post:master;dm-hub-integration-rupost:master;dm-hub-integration-telegram:master;dm-hub-integration-upu:master;dm-hub-integration-wms:master;dm-hub-workflow-asn:master;dm-hub-workflow-email:master;dm-hub-workflow-hub-external:master;dm-hub-workflow-hub-internal:master;dm-hub-workflow-integration:master;dm-hub-workflow-package:master;dm-hub-workflow-tracking:master;dm-hub-workflow-hub-internal:master;dm-hub-service-packing:master;dm-hub-service-cargo:master;dm-hub-workflow-hub-external:master", "Authorization": "Bearer 0ae2e3d0-640e-443c-bc10-88a48455a831"}, "json": {"invoiceId": 1807, "gateBarcode": "QA_AUTO_GATE_DECLARED_7"}, "timeout": 30}
INFO     src.framework.common.api:api.py:121 {"timestamp": "2026-04-04T23:51:11.459069", "type": "response", "method": "POST", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/acceptance/invoices", "status_code": 200, "trace_id": "de38ac2e52b2871180a25d5016bef1fb", "headers": {}, "body": "", "elapsed_time": 0.027712, "reason": "OK"}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT invoice.id, invoice.lk_invoice_id, invoice.original_invoice_number, invoice.need_mark, invoice.has_expiration_date, invoice.is_declared, invoice.invoice_status, invoice.date_create, invoice.vehicle_id, invoice.is_test, invoice.date_arrival, invoice.seller_id, invoice.warehouse_id, invoice.gtd_number, invoice.date_update, invoice.date_finished, invoice.partner_id 
FROM invoice 
WHERE invoice.original_invoice_number = %(original_invoice_number_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 675.2s ago] {'original_invoice_number_1': '75346651129259520'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT vehicle.id AS vehicle_id, vehicle.car_license_plate AS vehicle_car_license_plate 
FROM vehicle 
WHERE vehicle.id = %(pk_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 543.6s ago] {'pk_1': 1988}
INFO     src.framework.common.api:api.py:97 {"timestamp": "2026-04-04T23:51:11.462200", "type": "request", "method": "POST", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/acceptance/task/pick", "headers": {"x-aer-mock-hub": "true", "x-aer-mock-lp": "true", "x-aer-mock-ff": "true", "x-aer-mock-yandex-bond": "true", "x-aer-mock-egov-uz": "true", "x-aer-mock-tmg": "true", "x-aer-mesh": "dm-hub-service-package:master;dm-hub-service-package-external:master;dm-hub-service-sorting:master;dm-hub-service-asn:master;dm-hub-service-inbound:master;dm-hub-service-meta:master;dm-hub-service-configuration:master;dm-hub-service-packing:master;dm-hub-service-dispatch:master;dm-hub-service-label:master;dm-hub-service-storage:master;dm-hub-service-cargo:master;dm-hub-service-country:master;dm-hub-service-customs:master;dm-hub-service-document:master;dm-hub-service-email:master;dm-hub-service-file-storage:master;dm-hub-service-inspection:master;dm-hub-service-osl:master;dm-hub-service-partners:master;dm-hub-service-report:master;dm-hub-service-settings:master;dm-hub-service-short-link:master;dm-hub-service-templates:master;dm-hub-service-tracking:master;dm-hub-service-transliteration:master;dm-hub-service-processing:master;dm-hub-api-cargo-carrier:master;dm-hub-api-fe:master;dm-hub-api-ff:master;dm-hub-api-wms:master;dm-hub-api-aer:master;dm-hub-api-joom:master;dm-hub-api-gateway:master;dm-hub-api-partners:master;dm-hub-api-pochta-global:master;dm-hub-api-public:master;dm-hub-api-wildberries:master;dm-hub-api-internal:master;dm-hub-daemon-package-process:master;dm-hub-daemon-tracking:master;dm-hub-integration-ff:master;dm-hub-integration-aer:master;dm-hub-integration-cainiao:master;dm-hub-integration-cargo-carrier:master;dm-hub-integration-gtt:master;dm-hub-integration-kazpost:master;dm-hub-integration-kgpost:master;dm-hub-integration-partners:master;dm-hub-integration-post:master;dm-hub-integration-rupost:master;dm-hub-integration-telegram:master;dm-hub-integration-upu:master;dm-hub-integration-wms:master;dm-hub-workflow-asn:master;dm-hub-workflow-email:master;dm-hub-workflow-hub-external:master;dm-hub-workflow-hub-internal:master;dm-hub-workflow-integration:master;dm-hub-workflow-package:master;dm-hub-workflow-tracking:master;dm-hub-workflow-hub-internal:master;dm-hub-service-packing:master;dm-hub-service-cargo:master;dm-hub-workflow-hub-external:master", "Authorization": "Bearer 0ae2e3d0-640e-443c-bc10-88a48455a831"}, "json": {"gateId": 9999997, "vehicleLicencePlate": "36159738929685", "taskPalletFlowType": "NEW"}, "timeout": 30}
INFO     src.framework.common.api:api.py:121 {"timestamp": "2026-04-04T23:51:11.496614", "type": "response", "method": "POST", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/acceptance/task/pick", "status_code": 200, "trace_id": "3624c19a030d2c376aac79c0edf264d7", "headers": {}, "body": "{\"id\":991,\"status\":\"CREATED\",\"gateId\":9999997,\"gateBarcode\":\"QA_AUTO_GATE_DECLARED_7\",\"vehicleLicencePlate\":\"36159738929685\",\"items\":[],\"palletBarcode\":null,\"prePlacedCell\":null,\"weight\":0,\"taskPalletFlowType\":\"NEW\"}", "elapsed_time": 0.033241, "reason": "OK"}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT unloading_task.id, unloading_task.invoice_id, unloading_task.worker_id, unloading_task.status, unloading_task.date_create, unloading_task.date_update, unloading_task.pallet_barcode, unloading_task.pre_placed_cell_id, unloading_task.date_of_manufacture, unloading_task.expiration_date, unloading_task.shelf_life, unloading_task.pallet_weight, unloading_task.task_pallet_flow_type 
FROM unloading_task 
WHERE unloading_task.invoice_id = %(invoice_id_1)s ORDER BY unloading_task.id DESC
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 543.6s ago] {'invoice_id_1': 1807}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT invoice.id, invoice.lk_invoice_id, invoice.original_invoice_number, invoice.need_mark, invoice.has_expiration_date, invoice.is_declared, invoice.invoice_status, invoice.date_create, invoice.vehicle_id, invoice.is_test, invoice.date_arrival, invoice.seller_id, invoice.warehouse_id, invoice.gtd_number, invoice.date_update, invoice.date_finished, invoice.partner_id 
FROM invoice 
WHERE invoice.original_invoice_number = %(original_invoice_number_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 675.2s ago] {'original_invoice_number_1': '75346651129259520'}
INFO     sqlalchemy.engine.Engine:base.py:1846 SELECT unloading_task.id AS unloading_task_id, unloading_task.invoice_id AS unloading_task_invoice_id, unloading_task.worker_id AS unloading_task_worker_id, unloading_task.status AS unloading_task_status, unloading_task.date_create AS unloading_task_date_create, unloading_task.date_update AS unloading_task_date_update, unloading_task.pallet_barcode AS unloading_task_pallet_barcode, unloading_task.pre_placed_cell_id AS unloading_task_pre_placed_cell_id, unloading_task.date_of_manufacture AS unloading_task_date_of_manufacture, unloading_task.expiration_date AS unloading_task_expiration_date, unloading_task.shelf_life AS unloading_task_shelf_life, unloading_task.pallet_weight AS unloading_task_pallet_weight, unloading_task.task_pallet_flow_type AS unloading_task_task_pallet_flow_type 
FROM unloading_task 
WHERE unloading_task.id = %(pk_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 543.5s ago] {'pk_1': 991}
INFO     src.framework.common.api:api.py:97 {"timestamp": "2026-04-04T23:51:11.501831", "type": "request", "method": "POST", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/acceptance-item", "headers": {"x-aer-mock-hub": "true", "x-aer-mock-lp": "true", "x-aer-mock-ff": "true", "x-aer-mock-yandex-bond": "true", "x-aer-mock-egov-uz": "true", "x-aer-mock-tmg": "true", "x-aer-mesh": "dm-hub-service-package:master;dm-hub-service-package-external:master;dm-hub-service-sorting:master;dm-hub-service-asn:master;dm-hub-service-inbound:master;dm-hub-service-meta:master;dm-hub-service-configuration:master;dm-hub-service-packing:master;dm-hub-service-dispatch:master;dm-hub-service-label:master;dm-hub-service-storage:master;dm-hub-service-cargo:master;dm-hub-service-country:master;dm-hub-service-customs:master;dm-hub-service-document:master;dm-hub-service-email:master;dm-hub-service-file-storage:master;dm-hub-service-inspection:master;dm-hub-service-osl:master;dm-hub-service-partners:master;dm-hub-service-report:master;dm-hub-service-settings:master;dm-hub-service-short-link:master;dm-hub-service-templates:master;dm-hub-service-tracking:master;dm-hub-service-transliteration:master;dm-hub-service-processing:master;dm-hub-api-cargo-carrier:master;dm-hub-api-fe:master;dm-hub-api-ff:master;dm-hub-api-wms:master;dm-hub-api-aer:master;dm-hub-api-joom:master;dm-hub-api-gateway:master;dm-hub-api-partners:master;dm-hub-api-pochta-global:master;dm-hub-api-public:master;dm-hub-api-wildberries:master;dm-hub-api-internal:master;dm-hub-daemon-package-process:master;dm-hub-daemon-tracking:master;dm-hub-integration-ff:master;dm-hub-integration-aer:master;dm-hub-integration-cainiao:master;dm-hub-integration-cargo-carrier:master;dm-hub-integration-gtt:master;dm-hub-integration-kazpost:master;dm-hub-integration-kgpost:master;dm-hub-integration-partners:master;dm-hub-integration-post:master;dm-hub-integration-rupost:master;dm-hub-integration-telegram:master;dm-hub-integration-upu:master;dm-hub-integration-wms:master;dm-hub-workflow-asn:master;dm-hub-workflow-email:master;dm-hub-workflow-hub-external:master;dm-hub-workflow-hub-internal:master;dm-hub-workflow-integration:master;dm-hub-workflow-package:master;dm-hub-workflow-tracking:master;dm-hub-workflow-hub-internal:master;dm-hub-service-packing:master;dm-hub-service-cargo:master;dm-hub-workflow-hub-external:master", "Authorization": "Bearer 0ae2e3d0-640e-443c-bc10-88a48455a831"}, "json": {"barcode": "20211236266533", "unloadingTaskId": 991}, "timeout": 30}
INFO     src.framework.common.api:api.py:121 {"timestamp": "2026-04-04T23:51:11.533941", "type": "response", "method": "POST", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/acceptance-item", "status_code": 200, "trace_id": "31500c10a2cce971e35bb7fecb2acd56", "headers": {}, "body": "{\"invoiceId\":1807,\"skuId\":\"75346656267656192\",\"barcode\":\"20211236266533\",\"isBundle\":true,\"name\":\"QA name Домашний инфекция очко плод способ.\",\"amountInBundle\":10,\"description\":null,\"imageUrl\":\"https://placekitten.com/461/985\",\"hasMark\":false,\"hasExpirationDate\":false,\"weight\":765,\"unloadingTaskItemId\":972,\"totalCount\":0,\"markCount\":0}", "elapsed_time": 0.03095, "reason": "OK"}
INFO     src.framework.common.api:api.py:97 {"timestamp": "2026-04-04T23:51:11.534971", "type": "request", "method": "PUT", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/acceptance-item/add-count", "headers": {"x-aer-mock-hub": "true", "x-aer-mock-lp": "true", "x-aer-mock-ff": "true", "x-aer-mock-yandex-bond": "true", "x-aer-mock-egov-uz": "true", "x-aer-mock-tmg": "true", "x-aer-mesh": "dm-hub-service-package:master;dm-hub-service-package-external:master;dm-hub-service-sorting:master;dm-hub-service-asn:master;dm-hub-service-inbound:master;dm-hub-service-meta:master;dm-hub-service-configuration:master;dm-hub-service-packing:master;dm-hub-service-dispatch:master;dm-hub-service-label:master;dm-hub-service-storage:master;dm-hub-service-cargo:master;dm-hub-service-country:master;dm-hub-service-customs:master;dm-hub-service-document:master;dm-hub-service-email:master;dm-hub-service-file-storage:master;dm-hub-service-inspection:master;dm-hub-service-osl:master;dm-hub-service-partners:master;dm-hub-service-report:master;dm-hub-service-settings:master;dm-hub-service-short-link:master;dm-hub-service-templates:master;dm-hub-service-tracking:master;dm-hub-service-transliteration:master;dm-hub-service-processing:master;dm-hub-api-cargo-carrier:master;dm-hub-api-fe:master;dm-hub-api-ff:master;dm-hub-api-wms:master;dm-hub-api-aer:master;dm-hub-api-joom:master;dm-hub-api-gateway:master;dm-hub-api-partners:master;dm-hub-api-pochta-global:master;dm-hub-api-public:master;dm-hub-api-wildberries:master;dm-hub-api-internal:master;dm-hub-daemon-package-process:master;dm-hub-daemon-tracking:master;dm-hub-integration-ff:master;dm-hub-integration-aer:master;dm-hub-integration-cainiao:master;dm-hub-integration-cargo-carrier:master;dm-hub-integration-gtt:master;dm-hub-integration-kazpost:master;dm-hub-integration-kgpost:master;dm-hub-integration-partners:master;dm-hub-integration-post:master;dm-hub-integration-rupost:master;dm-hub-integration-telegram:master;dm-hub-integration-upu:master;dm-hub-integration-wms:master;dm-hub-workflow-asn:master;dm-hub-workflow-email:master;dm-hub-workflow-hub-external:master;dm-hub-workflow-hub-internal:master;dm-hub-workflow-integration:master;dm-hub-workflow-package:master;dm-hub-workflow-tracking:master;dm-hub-workflow-hub-internal:master;dm-hub-service-packing:master;dm-hub-service-cargo:master;dm-hub-workflow-hub-external:master", "Authorization": "Bearer 0ae2e3d0-640e-443c-bc10-88a48455a831"}, "json": {"unloadingTaskItemId": 972, "count": 1}, "timeout": 30}
INFO     src.framework.common.api:api.py:121 {"timestamp": "2026-04-04T23:51:11.565515", "type": "response", "method": "PUT", "url": "https://dm-fmcg-be-facade-fe.k8s-review.dailymail-tech.uz/api/v1/acceptance-item/add-count", "status_code": 400, "trace_id": "bccd3da96543cc6799d10a9eda28670e", "headers": {}, "body": "{\"message\":\"Total counted for SKU would exceed expected: totalAfter=10, expected=9, skuLkId=3719\",\"localizedMessage\":\"Количество товара превысит ожидаемое: 10 > 9\"}", "elapsed_time": 0.029226, "reason": "Bad Request"}
INFO     sqlalchemy.engine.Engine:base.py:2713 ROLLBACK using DBAPI connection.rollback(); set skip_autocommit_rollback to prevent fully
INFO     sqlalchemy.engine.Engine:base.py:2713 ROLLBACK using DBAPI connection.rollback(); set skip_autocommit_rollback to prevent fully
INFO     sqlalchemy.engine.Engine:base.py:2710 BEGIN (implicit; DBAPI should not BEGIN due to autocommit mode)
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE unloading_task SET worker_id=%(worker_id)s WHERE (unloading_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND unloading_task.worker_id = %(worker_id_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [generated in 0.00019s] {'worker_id': 0, 'worker_id_1': 9000000001, 'status_1_1': <AcceptanceUnloadingTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <AcceptanceUnloadingTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE placed_unloading_task SET stock_cell_barcode=%(stock_cell_barcode)s, worker_id=%(worker_id)s WHERE placed_unloading_task.status != %(status_1)s AND placed_unloading_task.worker_id = %(worker_id_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [generated in 0.00016s] {'stock_cell_barcode': None, 'worker_id': 0, 'status_1': <AcceptancePlacedUnloadingTaskStatus.COMPLETED: 'COMPLETED'>, 'worker_id_1': 9000000001}
INFO     sqlalchemy.engine.Engine:base.py:1846 select pg_catalog.version()
INFO     sqlalchemy.engine.Engine:base.py:1846 [raw sql] {}
INFO     sqlalchemy.engine.Engine:base.py:1846 select current_schema()
INFO     sqlalchemy.engine.Engine:base.py:1846 [raw sql] {}
INFO     sqlalchemy.engine.Engine:base.py:1846 show standard_conforming_strings
INFO     sqlalchemy.engine.Engine:base.py:1846 [raw sql] {}
INFO     sqlalchemy.engine.Engine:base.py:2710 BEGIN (implicit; DBAPI should not BEGIN due to autocommit mode)
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE withdrawal_task SET worker=%(worker)s WHERE (withdrawal_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND withdrawal_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [generated in 0.00013s] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearanceWithdrawalTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearanceWithdrawalTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE transfer_task SET worker=%(worker)s WHERE (transfer_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND transfer_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [generated in 0.00014s] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearanceTransferTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearanceTransferTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE placement_task SET worker=%(worker)s WHERE (placement_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND placement_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [generated in 0.00013s] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearancePlacementTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearancePlacementTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE unloading_task SET worker_id=%(worker_id)s WHERE (unloading_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND unloading_task.worker_id = %(worker_id_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.04069s ago] {'worker_id': 0, 'worker_id_1': 9000000001, 'status_1_1': <AcceptanceUnloadingTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <AcceptanceUnloadingTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE placed_unloading_task SET stock_cell_barcode=%(stock_cell_barcode)s, worker_id=%(worker_id)s WHERE placed_unloading_task.status != %(status_1)s AND placed_unloading_task.worker_id = %(worker_id_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.03672s ago] {'stock_cell_barcode': None, 'worker_id': 0, 'status_1': <AcceptancePlacedUnloadingTaskStatus.COMPLETED: 'COMPLETED'>, 'worker_id_1': 9000000001}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE withdrawal_task SET worker=%(worker)s WHERE (withdrawal_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND withdrawal_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.01185s ago] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearanceWithdrawalTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearanceWithdrawalTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE transfer_task SET worker=%(worker)s WHERE (transfer_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND transfer_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.007868s ago] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearanceTransferTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearanceTransferTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE placement_task SET worker=%(worker)s WHERE (placement_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND placement_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.006327s ago] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearancePlacementTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearancePlacementTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE unloading_task SET worker_id=%(worker_id)s WHERE (unloading_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND unloading_task.worker_id = %(worker_id_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.0456s ago] {'worker_id': 0, 'worker_id_1': 9000000001, 'status_1_1': <AcceptanceUnloadingTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <AcceptanceUnloadingTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE placed_unloading_task SET stock_cell_barcode=%(stock_cell_barcode)s, worker_id=%(worker_id)s WHERE placed_unloading_task.status != %(status_1)s AND placed_unloading_task.worker_id = %(worker_id_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.04135s ago] {'stock_cell_barcode': None, 'worker_id': 0, 'status_1': <AcceptancePlacedUnloadingTaskStatus.COMPLETED: 'COMPLETED'>, 'worker_id_1': 9000000001}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE withdrawal_task SET worker=%(worker)s WHERE (withdrawal_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND withdrawal_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.01645s ago] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearanceWithdrawalTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearanceWithdrawalTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE transfer_task SET worker=%(worker)s WHERE (transfer_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND transfer_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.01244s ago] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearanceTransferTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearanceTransferTaskStatus.CANCELLED: 'CANCELLED'>}
INFO     sqlalchemy.engine.Engine:base.py:1846 UPDATE placement_task SET worker=%(worker)s WHERE (placement_task.status NOT IN (%(status_1_1)s, %(status_1_2)s)) AND placement_task.worker = %(worker_1)s
INFO     sqlalchemy.engine.Engine:base.py:1846 [cached since 0.01085s ago] {'worker': None, 'worker_1': 9000000001, 'status_1_1': <CustomsClearancePlacementTaskStatus.COMPLETED: 'COMPLETED'>, 'status_1_2': <CustomsClearancePlacementTaskStatus.CANCELLED: 'CANCELLED'>}