srenblad
/
artiq
forked from M-Labs/artiq
1
0
Fork 0
Code Pull Requests Activity

master/worker_db: style

This commit is contained in:
Sebastien Bourdeauducq 2016-04-14 19:14:20 +08:00
parent 69f534cc20
commit c97cb1d3b9
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
artiq/master/worker_db.py
View File

@ -6,7 +6,6 @@ import tempfile
import time import time
import re import re
import numpy as np
import h5py import h5py
from artiq.protocols.sync_struct import Notifier from artiq.protocols.sync_struct import Notifier
@ -44,7 +43,8 @@ class RIDCounter:
def _update_cache(self, rid): def _update_cache(self, rid):
contents = str(rid) + "\n" contents = str(rid) + "\n"
directory = os.path.abspath(os.path.dirname(self.cache_filename)) directory = os.path.abspath(os.path.dirname(self.cache_filename))
with tempfile.NamedTemporaryFile("w", dir=directory, delete=False) as f: with tempfile.NamedTemporaryFile("w", dir=directory, delete=False
) as f:
f.write(contents) f.write(contents)
tmpname = f.name tmpname = f.name
os.replace(tmpname, self.cache_filename) os.replace(tmpname, self.cache_filename)
@ -68,7 +68,7 @@ class RIDCounter:
except: except:
continue continue
minute_folders = filter(lambda x: re.fullmatch('\d\d-\d\d', x), minute_folders = filter(lambda x: re.fullmatch('\d\d-\d\d', x),
minute_folders) minute_folders)
for mf in minute_folders: for mf in minute_folders:
minute_path = os.path.join(day_path, mf) minute_path = os.path.join(day_path, mf)
try: try: