Skip to content
Snippets Groups Projects
Commit 83b42a46 authored by Nick Bearson's avatar Nick Bearson
Browse files

move our realtime handling outside of grid_setup

parent 255fea52
No related branches found
No related tags found
1 merge request!26group inputs by minute and process accordingly
...@@ -191,19 +191,6 @@ def grid_setup(args, work_dir=os.getcwd()): ...@@ -191,19 +191,6 @@ def grid_setup(args, work_dir=os.getcwd()):
min_events = None min_events = None
min_groups = None min_groups = None
if args.realtime:
if len(args.filenames) != 1:
log.error("realtime mode only accepts one input file")
exit(1)
glminfo = parse_glm_filename(os.path.basename(args.filenames[0]))
globstring = "{}_{}_{}_s{}*".format(glminfo[0], glminfo[1], glminfo[2], glminfo[3].strftime("%Y%j%H%M"))
fileglob = glob(os.path.join(os.path.dirname(args.filenames[0]), globstring))
if len(fileglob) != 3:
log.error("There are not (yet) three GLM files from this minute. This may be expected. Exiting.")
exit(0)
args.filenames = fileglob
for f in args.filenames: for f in args.filenames:
if not os.path.exists(f): if not os.path.exists(f):
log.error("Tried to grid file that does not exist: {}".format(f)) log.error("Tried to grid file that does not exist: {}".format(f))
...@@ -331,6 +318,19 @@ if __name__ == '__main__': ...@@ -331,6 +318,19 @@ if __name__ == '__main__':
log.info("Starting GLM Gridding") log.info("Starting GLM Gridding")
log.debug("Starting script with: %s", sys.argv) log.debug("Starting script with: %s", sys.argv)
if args.realtime:
if len(args.filenames) != 1:
log.error("realtime mode only accepts one input file")
exit(1)
glminfo = parse_glm_filename(os.path.basename(args.filenames[0]))
globstring = "{}_{}_{}_s{}*".format(glminfo[0], glminfo[1], glminfo[2], glminfo[3].strftime("%Y%j%H%M"))
fileglob = glob(os.path.join(os.path.dirname(args.filenames[0]), globstring))
if len(fileglob) != 3:
log.error("There are not (yet) three GLM files from this minute. This may be expected. Exiting.")
exit(0)
args.filenames = fileglob
# set up output dir # set up output dir
os.makedirs(args.output_dir, exist_ok=True) os.makedirs(args.output_dir, exist_ok=True)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment