mirror of
https://github.com/GSA/notifications-api.git
synced 2026-01-30 06:21:50 -05:00
Merge pull request #1942 from alphagov/fix-old-jobs
Clean up old, incomplete jobs
This commit is contained in:
30
migrations/versions/0203_fix_old_incomplete_jobs.py
Normal file
30
migrations/versions/0203_fix_old_incomplete_jobs.py
Normal file
@@ -0,0 +1,30 @@
|
|||||||
|
"""empty message
|
||||||
|
|
||||||
|
Revision ID: 0203_fix_old_incomplete_jobs
|
||||||
|
Revises: 0202_new_letter_pricing
|
||||||
|
Create Date: 2017-06-29 12:44:16.815039
|
||||||
|
|
||||||
|
"""
|
||||||
|
|
||||||
|
# revision identifiers, used by Alembic.
|
||||||
|
revision = '0203_fix_old_incomplete_jobs'
|
||||||
|
down_revision = '0202_new_letter_pricing'
|
||||||
|
|
||||||
|
from alembic import op
|
||||||
|
|
||||||
|
|
||||||
|
def upgrade():
|
||||||
|
op.execute("""
|
||||||
|
UPDATE
|
||||||
|
jobs
|
||||||
|
SET
|
||||||
|
processing_started = created_at
|
||||||
|
WHERE
|
||||||
|
processing_started IS NULL
|
||||||
|
AND
|
||||||
|
job_status = 'in progress'
|
||||||
|
""")
|
||||||
|
|
||||||
|
|
||||||
|
def downgrade():
|
||||||
|
pass
|
||||||
Reference in New Issue
Block a user