updated bool in argparse
This commit is contained in:
@@ -13,7 +13,7 @@ python crystfel_split.py -l <path-to-list-file>
|
|||||||
-g <path-to-geom-file>
|
-g <path-to-geom-file>
|
||||||
-c <path-to-cell-file>
|
-c <path-to-cell-file>
|
||||||
-n <name-of-job>
|
-n <name-of-job>
|
||||||
-e name of endstation
|
-p photons or
|
||||||
|
|
||||||
# crystfel parameter may need some editing in the function - write_crystfel_run
|
# crystfel parameter may need some editing in the function - write_crystfel_run
|
||||||
|
|
||||||
@@ -24,11 +24,11 @@ a log file with .geom and evalation of indexing, cell etc
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
# modules
|
# modules
|
||||||
|
import argparse
|
||||||
import pandas as pd
|
import pandas as pd
|
||||||
import subprocess
|
import subprocess
|
||||||
import os, errno
|
import os, errno
|
||||||
import time
|
import time
|
||||||
import argparse
|
|
||||||
from tqdm import tqdm
|
from tqdm import tqdm
|
||||||
import regex as re
|
import regex as re
|
||||||
import numpy as np
|
import numpy as np
|
||||||
@@ -229,7 +229,7 @@ def wait_for_jobs( job_ids, total_jobs ):
|
|||||||
job_ids.difference_update(completed_jobs)
|
job_ids.difference_update(completed_jobs)
|
||||||
time.sleep(2)
|
time.sleep(2)
|
||||||
|
|
||||||
def run_splits( list_df, cwd, name, lst, chunk_size, geom_file, cell_file, threshold, reservation ):
|
def run_splits( list_df, cwd, name, geom_file, cell_file, threshold, reservation ):
|
||||||
|
|
||||||
# set chunk counter
|
# set chunk counter
|
||||||
chunk = 0
|
chunk = 0
|
||||||
@@ -281,7 +281,7 @@ def main( cwd, name, lst, chunk_size, geom_file, cell_file, threshold, reservati
|
|||||||
|
|
||||||
# run crystfel runs on individual splits
|
# run crystfel runs on individual splits
|
||||||
print( "submitting jobs to cluster" )
|
print( "submitting jobs to cluster" )
|
||||||
submitted_job_ids, chunk, stream_lst = run_splits( list_df, cwd, name, lst, chunk_size, geom_file, cell_file, threshold, reservation )
|
submitted_job_ids, chunk, stream_lst = run_splits( list_df, cwd, name, geom_file, cell_file, threshold, reservation )
|
||||||
|
|
||||||
# monitor progress of jobs
|
# monitor progress of jobs
|
||||||
time.sleep( 30 )
|
time.sleep( 30 )
|
||||||
|
|||||||
Reference in New Issue
Block a user