kopia lustrzana https://github.com/bugout-dev/moonstream
Delete moonworm from seer abi jobs.
rodzic
b724ccf3b8
commit
bddc5544f9
|
@ -707,7 +707,7 @@ def add_abi_to_db(
|
||||||
"status": "active",
|
"status": "active",
|
||||||
"historical_crawl_status": "pending",
|
"historical_crawl_status": "pending",
|
||||||
"progress": 0,
|
"progress": 0,
|
||||||
"moonworm_task_pickedup": False,
|
"task_pickedup": False,
|
||||||
"abi": json.dumps(abi),
|
"abi": json.dumps(abi),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -141,7 +141,7 @@ def create_v3_task(
|
||||||
"status": "active",
|
"status": "active",
|
||||||
"historical_crawl_status": "pending",
|
"historical_crawl_status": "pending",
|
||||||
"progress": 0,
|
"progress": 0,
|
||||||
"moonworm_task_pickedup": False,
|
"task_pickedup": False,
|
||||||
"abi": json.dumps(abi_task),
|
"abi": json.dumps(abi_task),
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
@ -318,7 +318,7 @@ def migrate_v3_tasks(
|
||||||
"status": "active",
|
"status": "active",
|
||||||
"historical_crawl_status": "pending",
|
"historical_crawl_status": "pending",
|
||||||
"progress": 0,
|
"progress": 0,
|
||||||
"moonworm_task_pickedup": False,
|
"task_pickedup": False,
|
||||||
"abi": json.dumps(abi_task),
|
"abi": json.dumps(abi_task),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -0,0 +1,38 @@
|
||||||
|
"""remove-old-name
|
||||||
|
|
||||||
|
Revision ID: 8647da37ed5a
|
||||||
|
Revises: 48d2562504d1
|
||||||
|
Create Date: 2024-08-22 17:10:28.949610
|
||||||
|
|
||||||
|
"""
|
||||||
|
|
||||||
|
from typing import Sequence, Union
|
||||||
|
|
||||||
|
from alembic import op
|
||||||
|
import sqlalchemy as sa
|
||||||
|
|
||||||
|
|
||||||
|
# revision identifiers, used by Alembic.
|
||||||
|
revision: str = "8647da37ed5a"
|
||||||
|
down_revision: Union[str, None] = "48d2562504d1"
|
||||||
|
branch_labels: Union[str, Sequence[str], None] = None
|
||||||
|
depends_on: Union[str, Sequence[str], None] = None
|
||||||
|
|
||||||
|
|
||||||
|
def upgrade() -> None:
|
||||||
|
# ### commands auto generated by Alembic - please adjust! ###
|
||||||
|
op.add_column("abi_jobs", sa.Column("task_pickedup", sa.Boolean(), nullable=False))
|
||||||
|
op.drop_column("abi_jobs", "moonworm_task_pickedup")
|
||||||
|
# ### end Alembic commands ###
|
||||||
|
|
||||||
|
|
||||||
|
def downgrade() -> None:
|
||||||
|
# ### commands auto generated by Alembic - please adjust! ###
|
||||||
|
op.add_column(
|
||||||
|
"abi_jobs",
|
||||||
|
sa.Column(
|
||||||
|
"moonworm_task_pickedup", sa.BOOLEAN(), autoincrement=False, nullable=False
|
||||||
|
),
|
||||||
|
)
|
||||||
|
op.drop_column("abi_jobs", "task_pickedup")
|
||||||
|
# ### end Alembic commands ###
|
|
@ -801,7 +801,7 @@ class AbiJobs(Base):
|
||||||
status = Column(VARCHAR(256), nullable=False, index=True)
|
status = Column(VARCHAR(256), nullable=False, index=True)
|
||||||
historical_crawl_status = Column(VARCHAR(256), nullable=False, index=True)
|
historical_crawl_status = Column(VARCHAR(256), nullable=False, index=True)
|
||||||
progress = Column(Integer, nullable=False, index=False)
|
progress = Column(Integer, nullable=False, index=False)
|
||||||
moonworm_task_pickedup = Column(Boolean, nullable=False, index=False)
|
task_pickedup = Column(Boolean, nullable=False, index=False)
|
||||||
abi = Column(Text, nullable=False)
|
abi = Column(Text, nullable=False)
|
||||||
created_at = Column(
|
created_at = Column(
|
||||||
DateTime(timezone=True), server_default=utcnow(), nullable=False
|
DateTime(timezone=True), server_default=utcnow(), nullable=False
|
||||||
|
|
Ładowanie…
Reference in New Issue