exostring/new_vk_parser
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

hotfix: undefined constants in insta_parser

Browse Source
This commit is contained in:
Your Name
2026-08-05 20:03:27 +05:00
parent ba43e61f89
commit 80c9353af4
1 changed files with 16 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/vk_parser_app/workers/insta_parser.py
+16 -12
View File
@@ -30,8 +30,10 @@ from loguru import logger
from ..config import settings from ..config import settings
from ..constants import ( from ..constants import (
PLATFORM_INSTAGRAM, PLATFORM_INSTAGRAM,
POST_STATUS_TRASH, POST_STATUS_STORAGE_PENDING,
POST_STATUS_MEDIA_PENDING, POST_STATUS_SKIPPED,
SOURCE_STATUS_ERROR,
SOURCE_STATUS_OK,
WORKER_INSTA_PARSER, WORKER_INSTA_PARSER,
) )
from ..db import fetch_setting, fetch_int_setting, get_pool from ..db import fetch_setting, fetch_int_setting, get_pool
@@ -108,12 +110,13 @@ class InstaParserWorker:
""" """
UPDATE sources UPDATE sources
SET active = FALSE, SET active = FALSE,
status = 'error', status = $1,
status_msg = $1, status_msg = $2,
last_checked_at = NOW(), last_checked_at = NOW(),
updated_at = NOW() updated_at = NOW()
WHERE id = $2 WHERE id = $3
""", """,
SOURCE_STATUS_ERROR,
reason[:1000], reason[:1000],
source_id, source_id,
) )
@@ -123,15 +126,16 @@ class InstaParserWorker:
await conn.execute( await conn.execute(
""" """
UPDATE sources UPDATE sources
SET status = 'ok', SET status = $1,
status_msg = NULL, status_msg = NULL,
last_checked_at = NOW(), last_checked_at = NOW(),
last_parsed_at = COALESCE($2, last_parsed_at), last_parsed_at = COALESCE($2, last_parsed_at),
updated_at = NOW() updated_at = NOW()
WHERE id = $1 WHERE id = $3
""", """,
source_id, SOURCE_STATUS_OK,
last_parsed_at, last_parsed_at,
source_id,
) )
async def save_cooldown(self, hours: int) -> None: async def save_cooldown(self, hours: int) -> None:
@@ -235,7 +239,7 @@ class InstaParserWorker:
str(v_url), str(v_url),
) )
if status == POST_STATUS_MEDIA_PENDING: if status == POST_STATUS_STORAGE_PENDING:
await conn.execute( await conn.execute(
""" """
INSERT INTO jobs (job_type, entity_type, entity_id, payload, status) INSERT INTO jobs (job_type, entity_type, entity_id, payload, status)
@@ -334,16 +338,16 @@ class InstaParserWorker:
has_media = media_type in (1, 2, 8) has_media = media_type in (1, 2, 8)
if not has_media: if not has_media:
if await self.save_post_and_media(source_id, post, POST_STATUS_TRASH, "no_media"): if await self.save_post_and_media(source_id, post, POST_STATUS_SKIPPED, "no_media"):
saved += 1 saved += 1
continue continue
if len(text) < min_text_length: if len(text) < min_text_length:
if await self.save_post_and_media(source_id, post, POST_STATUS_TRASH, "text_too_short"): if await self.save_post_and_media(source_id, post, POST_STATUS_SKIPPED, "text_too_short"):
saved += 1 saved += 1
continue continue
if await self.save_post_and_media(source_id, post, POST_STATUS_MEDIA_PENDING, None): if await self.save_post_and_media(source_id, post, POST_STATUS_STORAGE_PENDING, None):
saved += 1 saved += 1
except Exception as e: except Exception as e:
logger.error(f"Failed to save insta post {post.get('pk')}: {e}") logger.error(f"Failed to save insta post {post.get('pk')}: {e}")