comments on alembic changes. resolve invalid usage of log_service.create

This commit is contained in:
Curtis Castrapel 2018-02-26 12:08:31 -08:00
parent a28fdac242
commit cca3797669
3 changed files with 7 additions and 3 deletions

View File

@ -270,7 +270,7 @@ class CertificatesList(AuthenticatedResource):
cert = service.create(**data) cert = service.create(**data)
if isinstance(cert, Certificate): if isinstance(cert, Certificate):
# only log if created, not pending # only log if created, not pending
log_service.create(g.user, 'create_cert', 'OK', certificate=cert) log_service.create(g.user, 'create_cert', certificate=cert)
return cert return cert
return dict(message="You are not authorized to use the authority: {0}".format(data['authority'].name)), 403 return dict(message="You are not authorized to use the authority: {0}".format(data['authority'].name)), 403

View File

@ -18,6 +18,7 @@ session = db.session()
def upgrade(): def upgrade():
print("Querying for all entries in certificate_notification_associations.")
# Query for all entries in table # Query for all entries in table
results = session.query(certificate_notification_associations).with_entities( results = session.query(certificate_notification_associations).with_entities(
certificate_notification_associations.c.certificate_id, certificate_notification_associations.c.certificate_id,
@ -30,6 +31,7 @@ def upgrade():
for x in results: for x in results:
# If we've seen a pair already, delete the duplicates # If we've seen a pair already, delete the duplicates
if seen.get("{}-{}".format(x.certificate_id, x.notification_id)): if seen.get("{}-{}".format(x.certificate_id, x.notification_id)):
print("Deleting duplicate: {}".format(x))
d = session.query(certificate_notification_associations).filter(certificate_notification_associations.c.id==x.id) d = session.query(certificate_notification_associations).filter(certificate_notification_associations.c.id==x.id)
d.delete(synchronize_session=False) d.delete(synchronize_session=False)
seen["{}-{}".format(x.certificate_id, x.notification_id)] = True seen["{}-{}".format(x.certificate_id, x.notification_id)] = True

View File

@ -27,8 +27,10 @@ def upgrade():
TABLE, TABLE,
sa.Column('id', sa.Integer, primary_key=True, autoincrement=True) sa.Column('id', sa.Integer, primary_key=True, autoincrement=True)
) )
db.session.commit()
db.session.flush()
def downgrade(): def downgrade():
op.drop_column(TABLE, "id") op.drop_column(TABLE, "id")
db.session.commit()
db.session.flush()