Dmitry
c55fe19e48
Source.sync(ctx) -> SyncResult пишет только raw_* и возвращает курсор; локи, журнал, ошибки и продвижение курсора берёт на себя worker/runner. ZenMoney читается единственным доступным способом — POST /v8/diff/ по serverTimestamp; токен живёт сутки, поэтому worker ротирует refresh_token через source_credential. Маппер всегда пересобирает core из полных raw_*, так что удаление в ZenMoney исчезает и у нас. ЦБ ходит мимо прокси (trust_env=False) и отдаёт cp1251 с делением на Nominal. Курсы только по рабочим дням — протяжку по календарю делает аналитика. Планировщик — APScheduler в отдельном процессе, на источник advisory-лок sync:<name>, чтобы ручной запуск не пересёкся с плановым.
43 lines
1.3 KiB
Python
43 lines
1.3 KiB
Python
"""account balance columns
|
|
|
|
Revision ID: b1d54240abb8
|
|
Revises: 0506c15002c8
|
|
Create Date: 2026-09-17 22:40:21.874610
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
from collections.abc import Sequence
|
|
|
|
import sqlalchemy as sa
|
|
from alembic import op
|
|
|
|
revision: str = "b1d54240abb8"
|
|
down_revision: str | None = "0506c15002c8"
|
|
branch_labels: str | Sequence[str] | None = None
|
|
depends_on: str | Sequence[str] | None = None
|
|
|
|
|
|
def upgrade() -> None:
|
|
# ### commands auto generated by Alembic - please adjust! ###
|
|
op.add_column(
|
|
"account", sa.Column("balance", sa.Numeric(precision=24, scale=10), nullable=True)
|
|
)
|
|
op.add_column(
|
|
"account", sa.Column("start_balance", sa.Numeric(precision=24, scale=10), nullable=True)
|
|
)
|
|
op.add_column(
|
|
"account", sa.Column("credit_limit", sa.Numeric(precision=24, scale=10), nullable=True)
|
|
)
|
|
op.add_column("account", sa.Column("balance_as_of", sa.DateTime(timezone=True), nullable=True))
|
|
# ### end Alembic commands ###
|
|
|
|
|
|
def downgrade() -> None:
|
|
# ### commands auto generated by Alembic - please adjust! ###
|
|
op.drop_column("account", "balance_as_of")
|
|
op.drop_column("account", "credit_limit")
|
|
op.drop_column("account", "start_balance")
|
|
op.drop_column("account", "balance")
|
|
# ### end Alembic commands ###
|