# HG changeset patch # User rv43 # Date 1679489540 0 # Node ID 3342c0518d4c081298287f2c96580c383cc76ac4 # Parent 551d1ea2416d0976900e2efaeaacf1690f8eaded planemo upload for repository https://github.com/rolfverberg/galaxytools commit f8c4bdb31c20c468045ad5e6eb255a293244bc6c-dirty diff -r 551d1ea2416d -r 3342c0518d4c tomo_combine.py --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/tomo_combine.py Wed Mar 22 12:52:20 2023 +0000 @@ -0,0 +1,102 @@ +#!/usr/bin/env python3 + +import logging + +import argparse +import pathlib +import sys +#import tracemalloc + +from workflow.run_tomo import Tomo + +#from memory_profiler import profile +#@profile +def __main__(): + # Parse command line arguments + parser = argparse.ArgumentParser( + description='Reduce tomography data') + parser.add_argument('-i', '--input_file', + required=True, + type=pathlib.Path, + help='''Full or relative path to the input file (in Nexus format).''') + parser.add_argument('-o', '--output_file', + required=False, + type=pathlib.Path, + help='''Full or relative path to the output file (in yaml format).''') + parser.add_argument('--galaxy_flag', + action='store_true', + help='''Use this flag to run the scripts as a galaxy tool.''') + parser.add_argument('-l', '--log', +# type=argparse.FileType('w'), + default=sys.stdout, + help='Logging stream or filename') + parser.add_argument('--log_level', + choices=logging._nameToLevel.keys(), + default='INFO', + help='''Specify a preferred logging level.''') + parser.add_argument('--x_bounds', + required=False, + nargs=2, + type=int, + help='''Boundaries of reconstructed images in x-direction.''') + parser.add_argument('--y_bounds', + required=False, + nargs=2, + type=int, + help='''Boundaries of reconstructed images in y-direction.''') + args = parser.parse_args() + + # Set log configuration + # When logging to file, the stdout log level defaults to WARNING + logging_format = '%(asctime)s : %(levelname)s - %(module)s : %(funcName)s - %(message)s' + level = logging.getLevelName(args.log_level) + if args.log is sys.stdout: + logging.basicConfig(format=logging_format, level=level, force=True, + handlers=[logging.StreamHandler()]) + else: + if isinstance(args.log, str): + logging.basicConfig(filename=f'{args.log}', filemode='w', + format=logging_format, level=level, force=True) + elif isinstance(args.log, io.TextIOWrapper): + logging.basicConfig(filemode='w', format=logging_format, level=level, + stream=args.log, force=True) + else: + raise(ValueError(f'Invalid argument --log: {args.log}')) + stream_handler = logging.StreamHandler() + logging.getLogger().addHandler(stream_handler) + stream_handler.setLevel(logging.WARNING) + stream_handler.setFormatter(logging.Formatter(logging_format)) + + # Starting memory monitoring +# tracemalloc.start() + + # Log command line arguments + logging.info(f'input_file = {args.input_file}') + logging.info(f'output_file = {args.output_file}') + logging.debug(f'log = {args.log}') + logging.debug(f'is log stdout? {args.log is sys.stdout}') + logging.debug(f'log_level = {args.log_level}') + logging.info(f'x_bounds = {args.x_bounds}') + logging.info(f'y_bounds = {args.y_bounds}') + + # Instantiate Tomo object + tomo = Tomo(galaxy_flag=args.galaxy_flag) + + # Read input file + data = tomo.read(args.input_file) + + # Combine the reconstructed tomography stacks + data = tomo.combine_data(data, x_bounds=args.x_bounds, y_bounds=args.y_bounds) + + # Write output file + if data is not None: + data = tomo.write(data, args.output_file) + + # Displaying memory usage +# logging.info(f'Memory usage: {tracemalloc.get_traced_memory()}') + + # stopping memory monitoring +# tracemalloc.stop() + +if __name__ == "__main__": + __main__() diff -r 551d1ea2416d -r 3342c0518d4c tomo_combine.xml --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/tomo_combine.xml Wed Mar 22 12:52:20 2023 +0000 @@ -0,0 +1,47 @@ + + Combine reconstructed tomography stacks + + tomo_macros.xml + + + + + + +
+ + +
+
+ + +
+
+ + +
+
+ + + + + + + + + + +
diff -r 551d1ea2416d -r 3342c0518d4c workflow/run_tomo.py --- a/workflow/run_tomo.py Tue Mar 21 18:46:02 2023 +0000 +++ b/workflow/run_tomo.py Wed Mar 22 12:52:20 2023 +0000 @@ -302,7 +302,7 @@ if not isinstance(nxentry, NXentry): raise ValueError(f'Invalid nxentry ({nxentry})') if center_rows is not None: - if self.galaxy_flag + if self.galaxy_flag: is not is_int_pair(center_rows, ge=-1): raise ValueError(f'Invalid parameter center_rows ({center_rows})') if (center_rows[0] != -1 and center_rows[1] != -1 and