86efeeeac8
<!-- .github/pull_request_template.md --> ## Description <!-- Provide a clear description of the changes in this PR --> ## DCO Affirmation I affirm that all code in every commit of this pull request conforms to the terms of the Topoteretes Developer Certificate of Origin.
39 lines
1.2 KiB
Python
39 lines
1.2 KiB
Python
"""Add pipeline run status
|
|
|
|
Revision ID: 1d0bb7fede17
|
|
Revises: 482cd6517ce4
|
|
Create Date: 2025-05-19 10:58:15.993314
|
|
|
|
"""
|
|
|
|
from typing import Sequence, Union
|
|
|
|
from alembic import op
|
|
|
|
from cognee.infrastructure.databases.relational.get_relational_engine import get_relational_engine
|
|
from cognee.modules.pipelines.models.PipelineRun import PipelineRun, PipelineRunStatus
|
|
|
|
|
|
# revision identifiers, used by Alembic.
|
|
revision: str = "1d0bb7fede17"
|
|
down_revision: Union[str, None] = "482cd6517ce4"
|
|
branch_labels: Union[str, Sequence[str], None] = None
|
|
depends_on: Union[str, Sequence[str], None] = None
|
|
|
|
|
|
async def upgrade() -> None:
|
|
db_engine = get_relational_engine()
|
|
|
|
if db_engine.engine.dialect.name == "postgresql":
|
|
op.execute(
|
|
f"ALTER TYPE {PipelineRun.status} ADD VALUE IF NOT EXISTS '{str(PipelineRunStatus.DATASET_PROCESSING_INITIATED)}'"
|
|
)
|
|
else:
|
|
op.execute(f"""
|
|
ALTER TABLE {PipelineRun}
|
|
MODIFY COLUMN {PipelineRun.status} ENUM('{PipelineRunStatus.DATASET_PROCESSING_INITIATED}', '{PipelineRunStatus.DATASET_PROCESSING_STARTED}', '{PipelineRunStatus.DATASET_PROCESSING_COMPLETED}', '{PipelineRunStatus.DATASET_PROCESSING_ERRORED}') NOT NULL
|
|
""")
|
|
|
|
|
|
def downgrade() -> None:
|
|
pass
|