pk/atst
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Formatting

Browse Source
This commit is contained in:
richard-dds 2019-09-16 16:58:28 -04:00
parent c0a629ae9a
commit 97cefc7501
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
atst/jobs.py
View File

@ -68,15 +68,12 @@ def claim_for_update(resource):
try: try:
yield claimed yield claimed
finally: finally:
db.session.query(Model).filter( db.session.query(Model).filter(Model.id == resource.id).filter(
Model.id == resource.id Model.claimed_at != None
).filter(Model.claimed_at != None).update( ).update({"claimed_at": sql.null()}, synchronize_session=False)
{"claimed_at": sql.null()}, synchronize_session=False
)
def do_create_environment(csp: CloudProviderInterface, environment_id=None): def do_create_environment(csp: CloudProviderInterface, environment_id=None):
logger.info(environment_id)
environment = Environments.get(environment_id) environment = Environments.get(environment_id)
with claim_for_update(environment) as environment: with claim_for_update(environment) as environment: