j}dZddlZddlmZddlmZddlmZeje Z dZ ddhZ d e d ed efd Zd e d e d efdZd e d efdZded efdZy)aMerchant approve/reject decisions on candidate product pairs. The only writer of strategist_pairing_decisions. The pairing job rewrites its own table (strategist_product_neighbors) on every run; if decisions lived there, a merchant who rejected a pair would see it come back after the next catalogue sync. Keeping decisions in a separate table the job never touches is what makes a re-run safe. N)sql)execute_values)get_db_connectiongffffff?approvedrejected tenant_id decisionsreturnc |D]F}|jdtvstd|jddtt|Dcgc]$}|d|d|d|d|jdf&}}t } |j 5}t |tjdjtj|||jt|cd d d |jScc}w#1swYnxYwn6#t$r*|jt j#d |d wxYw |jy #|jwxYw) zCUpserts a batch of merchant decisions. Returns the number recorded.decisionzInvalid decision z; must be one of anchor_key neighbor_key pair_type decided_bya INSERT INTO {}.strategist_pairing_decisions (anchor_key, neighbor_key, pair_type, decision, decided_by) VALUES %s ON CONFLICT (anchor_key, neighbor_key, pair_type) DO UPDATE SET decision = EXCLUDED.decision, decided_by = EXCLUDED.decided_by, decided_at = CURRENT_TIMESTAMP Nz)Failed to record pairing decisions for %sT)exc_info)get_VALID_DECISIONS ValueErrorsortedrcursorrrSQLformat Identifiercommitlenclose Exceptionrollbackloggererror)rr entryrowsconncurs =/var/www/html/strategist-ai/app/services/pairing/decisions.pyrecordr&#sx/ 99Z (8 8#EIIj$9#<rFs*9   8 $ +!c!d!s!H Ls L Ld LCD$ Ad A Ar8