Improve logs and db upgrade
diff --git a/staffeln/conductor/backup.py b/staffeln/conductor/backup.py
index 0a330a7..1d38b4e 100755
--- a/staffeln/conductor/backup.py
+++ b/staffeln/conductor/backup.py
@@ -174,12 +174,12 @@
"project_id": project_id,
}
)
+ LOG.info("Start purge completed tasks.")
for queue in success_tasks:
- LOG.info("Start purge completed tasks.")
queue.delete_queue()
+ LOG.info("Start purge failed tasks.")
for queue in failed_tasks:
- LOG.info("Start purge failed tasks.")
queue.delete_queue()
def create_failed_backup_obj(self, task):
diff --git a/staffeln/db/sqlalchemy/alembic/versions/5b2e78435231_add_report_timestamp.py b/staffeln/db/sqlalchemy/alembic/versions/5b2e78435231_add_report_timestamp.py
index 293de1a..1abed60 100644
--- a/staffeln/db/sqlalchemy/alembic/versions/5b2e78435231_add_report_timestamp.py
+++ b/staffeln/db/sqlalchemy/alembic/versions/5b2e78435231_add_report_timestamp.py
@@ -20,7 +20,9 @@
def upgrade():
op.create_table(
"report_timestamp",
- sa.Column("id", sa.String(36), primary_key=True, nullable=False),
+ sa.Column(
+ "id", sa.String(36), primary_key=True, nullable=False, autoincrement=True
+ ),
sa.Column("created_at", sa.DateTime),
sa.Column("updated_at", sa.DateTime),
sa.Column("sender", sa.String(length=255), nullable=True),