|
|
@@ -186,7 +186,7 @@ def fetch_rows(conn, trace_ids: List[str], progress_every: int) -> Dict[str, dic
|
|
|
sql = """
|
|
|
SELECT qk, media_trace_id, media_params
|
|
|
FROM honor_ad_bid_events
|
|
|
- WHERE media_trace_id IN ({})
|
|
|
+ WHERE media = 'honor' AND media_trace_id IN ({})
|
|
|
"""
|
|
|
total_chunks = (len(trace_ids) + chunk_size - 1) // chunk_size
|
|
|
with conn.cursor() as cur:
|
|
|
@@ -213,7 +213,7 @@ def update_mysql(conn, trace_id: str, params: dict, dry_run: bool) -> bool:
|
|
|
sql = """
|
|
|
UPDATE honor_ad_bid_events
|
|
|
SET media_params = %s
|
|
|
- WHERE media_trace_id = %s
|
|
|
+ WHERE media = 'honor' AND media_trace_id = %s
|
|
|
"""
|
|
|
if dry_run:
|
|
|
return True
|
