|
|
@@ -102,7 +102,7 @@ async def get_title_oss_fission_list(db_client, config, content_id) -> list[dict
|
|
|
two_days_ago_dt = (datetime.now() - timedelta(days=2)).strftime('%Y%m%d')
|
|
|
sql = f"""
|
|
|
SELECT
|
|
|
- lavfi.oss_name, lavfi.fission_0_on_read, lacv.platform, lacv.cover_oss_path, lacv.user_id, max(lavfi.dt) as max_dt
|
|
|
+ lavfi.oss_name, lavfi.fission_0_on_read, lacv.platform, lacv.cover_oss_path, lacv.user_id
|
|
|
FROM
|
|
|
{FISSION_DETAIL_TABLE} lavfi
|
|
|
JOIN {LONG_ARTICLES_CRAWLER_TABLE} lacv on lavfi.oss_name = lacv.video_oss_path
|
