← back to Hollywood Price 2026
__pycache__/archive_267.cpython-314.pyc
32 lines
+
�Sj� � � � R t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI t ]P P ^ R4 ^ RI H
t
Rt]P P RR4 tRtRtR tR
tR tR t]R
8X d
]! 4 R# R# )aO Archive the Hollywood products with no live Momentum match (Steve 2026-07-12,
'archive gone, price live' split) + reflect in dw_unified mirror.
Reads archive_final.csv. Shopify: status->ARCHIVED. dw_unified.shopify_products:
status->ARCHIVED (shopify_id = gid). Idempotent (ledger + skip already-archived).
Reversible (un-archive). $0.N�lib)�gqlzarchive_final.csv�ledgerz archived.csvzsmutation($input:ProductInput!){ productUpdate(input:$input){
product{ id status } userErrors{ field message } } }z+query($id:ID!){ product(id:$id){ status } }c �z � \ P ! \ P P R 4 RR7 \ P ! \ P P R4 4 , FI p \ V 4 F7 p\
P ! RV4 pV' g K$ VP ^ 4 u u # KK R# )z#~/Projects/hollywood-import/**/.envT)� recursivez!~/Projects/hollywood-import/*.envz<postgresql://dw_admin:[^\s\"']+@127\.0\.0\.1:5432/dw_unifiedN)�glob�os�path�
expanduser�open�re�search�group)�f�line�ms �archive_267.py�connr s� � �
�Y�Y�r�w�w�)�)�*O�P�\`�
a�
�Y�Y�r�w�w�)�)�*M�N�
O�P� P����G�D�� � �Y�[_�`�A��q��w�w�q�z�!� �P� � c � � \ P P \ 4 ;' d' \ P P \ 4 ^ 8� ' * p\ \ RRR7 ;_uu_ 4 p\ P ! V4 pV' d VP . RO4 VP \ P P 4 P RR7 WV.4 RRR4 R# + ' g i R# ; i)� �a� )�newline�seconds)�timespecN)�ts�
product_id�title�status) r r �exists�LEDGER�getsizer �csv�writer�writerow�datetime�now� isoformat)�pidr r �newr �ws &&& r �logr, $ s� � ��w�w�~�~�f�%�E�E�"�'�'�/�/�&�*A�A�*E�
F�C�
�f�c�2� &� &�!� �J�J�q�M�� �
�J�J�>� ?� �
�
�H�%�%�)�)�+�5�5�y�5�I�3�W]�^�_�
'� &� &� &�s
�1A2C-�- C> c �b � \ 4 p \ P P \ 4 ' d| \
P ! \ \ 4 4 FT pVR , P R4 ' g K# VP R4 ' g K< V P VR, 4 KV V # )r �OKr ) �setr r r r! r# �
DictReaderr �
startswith�get�add)�s�rs r �seenr6 - sm � � ��A� �w�w�~�~�f� � �� � ��V� �-�A���{�%�%�d�+�+����l�0C�0C����a� �o�&� .�
�Hr c
�F � \ \ P ! \ \ 4 4 4 p \ 4 p^ ;p;r4. p\
V 4 EF� w rg\ VR, 4 q�R, p W�9 d V^,
pK1 \ \ RV /4 R, p
V
' g \ W�R, R4 V^,
pKp V
R, R8X d0 \ W�R, R 4 VP V 4 V^,
pK� \ \ R
RV RR//4 p V R , R , p V ' dB \ W�R, R
\ P ! V 4 R, , 4 V^,
pEK \ W�R, R4 VP V 4 V^,
pV^, ^, ^ 8X d+ \ RV^, R\! V 4 RV RV RV 2
4 \" P$ ! R4 EK� \ RV RV RV 24 \' 4 p
V
' d� V' d} RP) R V 4 4 pRV R2p\* P, ! RV
R V.R R R 7 p\ R VP. ;' g
VP0 P3 4 R, 4 R!# \ R 4 R!# )"r r �gid�id�productr zSKIP:not-foundr �ARCHIVEDzOK:already-archived�input�
productUpdate�
userErrorszFAIL::N�x Nr. z ...�/z ok=z skip=z fail=g333333�?zSHOPIFY ARCHIVE DONE: ok=�,c 3 �b " � T F% pR VP R R4 , R , x � K' R# 5i)�'r N)�replace)�.0�gs & r � <genexpr>�main.<locals>.<genexpr>Q s( � � �N�
�1��a�i�i��R� 0�0�3�6�6�
�s �-/zCUPDATE shopify_products SET status='ARCHIVED' WHERE shopify_id IN (z);�psqlz-tAcT)�capture_output�textzdw_unified update:z1dw_unified: skipped (no conn or nothing archived)N)�listr# r0 r �CSVr6 � enumerate�strr �Qr, �append�M_UPD�json�dumps�print�len�time�sleepr �join�
subprocess�run�stdout�stderr�strip)�rows�done�ok�skip�fail�
archived_gids�ir5 r) r8 �cur�d�ue�c�vals�sqls r �mainrl 6 s0 � � ����t�C�y�)� *�D� �6�D���B����M��$�����!�L�/�"��E�(�C� �;� �A�I�D�x��!�d�C�[�!�)�,��� ��w�Z�!1� 2�D�A�I�D�x� �x�=�J� &� ��w�Z�!6� 7� �9M�9M�c�9R�TV�Z[�T[�TV�]e� ���$��X�z�!B�C� D��
��
� �
-��
� ��w�Z��4�:�:�b�>�$�+?�!?� @�$�!�)�$�X� �C�7��T�"�M�$8�$8��$=�r�Q�w�r�
��E�R�<�1� � �E�!�A�#��a��D� �{�$�r�d�&���f�T�F�K� L� �
�
�4��! �"
� %�b�T���v�V�D�6�
B�C�
��A��]��x�x�N�
�N�N��S�TX�SY�Y[�\�� �N�N�F�A�v�s�3�D�t� T��
�"�Q�X�X�%9�%9����$@�$@�$B�4�$H�I�
�A�Br �__main__)�__doc__�sysr r# rS r r rZ r& rW r �insert�shopifyr rM rY r! rR rP r r, r6 rl �__name__� r r �<module>rt s� �� �
� �
� � � � � � � ������5� � ��� ��� � �h�� /�� :��1���`�
� C�F �z���F� r