darfix.tasks.hdf5_scans_concatenation.ConcatenateHDF5Scans#
- class darfix.tasks.hdf5_scans_concatenation.ConcatenateHDF5Scans(inputs=None, varinfo=None, node_id=None, node_attrs=None, execinfo=None, profile_directory=None)[source]#
Bases:
Task
Task to concatenate a set of scans / entries contained in ‘input_file’. If entries_to_concatenate is None then all entries will be concatenated
‘detector_data_path’ is the pattern to find all the detector data path. It
is expected to look like ‘{scan}/instrument/measurement/my_detector’. In this case it will look for each scan at the same location. So for the scan ‘1.1’ it will look for ‘1.1/instrument/measurement/my_detector’. For the scan 2.1 it will look for ‘2.1/instrument/measurement/my_detector’… If the {detector} is provided then all the dataset part of the upper path will be browse in order to ‘guess’ the detector to be used. Using the ‘find_detector’ function. * ‘positioners_group_path’ is the pattern to find all positioner groups. And should look like ‘{scan}/instrument/positioners’ For the scan ‘1.1’ it will look for ‘1.1/instrument/positioners’…
- Parameters:
inputs (
Optional
[Mapping
]) –varinfo (
Optional
[dict
]) –node_id (
Union
[str
,int
,tuple
,None
]) –node_attrs (
Optional
[dict
]) –execinfo (
Optional
[dict
]) –profile_directory (
Optional
[dict
]) –
- DEFAULT_DETECTOR_DATA_PATH = '{scan}/measurement/{detector}'#
- DEFAULT_POSITIONERS_DATA_PATH = '{scan}/instrument/positioners'#
- MISSING_DATA = <MISSING_DATA>#
- assert_ready_to_execute()#
- cancel()#
Function called when a task is cancelled. To be implemented by the derived classes
- property cancelled: bool#
Return True if the task has been cancelled by the user
- classmethod class_nonce()#
- classmethod class_nonce_data()#
- classmethod class_registry_name()#
- Return type:
Optional
[str
]
- cleanup_references()#
Removes all references to the inputs. Side effect: fixes the uhash of the task and outputs
- property done#
Completed (with or without exception)
- property exception#
- execute(force_rerun=False, raise_on_error=True, cleanup_references=False)#
- Parameters:
force_rerun (
Optional
[bool
]) –raise_on_error (
Optional
[bool
]) –cleanup_references (
Optional
[bool
]) –
- property failed#
Completed with exception
- fix_uhash()#
Fix the uhash when it is derived from the uhash data.
- get_input_uhashes()#
- get_input_value(key, default=<MISSING_DATA>)#
- Parameters:
default (
Any
) –
- get_input_values()#
- get_named_input_values()#
- get_output_transfer_data()#
The values are either DataUri or Variable
- get_output_uhashes()#
- get_output_value(key, default=<MISSING_DATA>)#
- Parameters:
default (
Any
) –
- get_output_values()#
- get_positional_input_values()#
- classmethod get_subclass(registry_name, _second_attempt=False)#
Retrieving a derived class
- classmethod get_subclass_names()#
- Return type:
List
[str
]
- classmethod get_subclasses()#
- get_uhash_init(serialize=False)#
- classmethod input_names()#
- property input_uhashes#
- property input_values#
DEPRECATED
- property input_variables#
- property inputs#
- instance_nonce()#
- classmethod instantiate(registry_name, **kw)#
Factory method for instantiating a derived class.
- Parameters:
registry_name (
str
) – for example “tasklib.tasks.MyTask” or “MyTask”**kw – Task constructor arguments
registry_name –
- Returns Task:
- property is_ready_to_execute#
- property job_id: str | None#
- property label#
- property missing_inputs#
- property missing_outputs#
- property named_input_values#
DEPRECATED
- property node_id: str | int | tuple#
- property npositional_inputs#
- classmethod optional_input_names()#
- property output_metadata: dict | None#
- classmethod output_names()#
- property output_transfer_data#
DEPRECATED
- property output_uhashes#
DEPRECATED
- property output_values#
DEPRECATED
- property output_variables#
- property outputs#
- property positional_input_values#
DEPRECATED
- classmethod required_input_names()#
- reset_state()#
- set_uhash_init(pre_uhash=None, instance_nonce=None)#
- Parameters:
pre_uhash (
Union
[str
,bytes
,UniversalHash
,HasUhash
,None
]) –instance_nonce (
Optional
[Any
]) –
- property succeeded#
Completed without exception and with output values
- property uhash: UniversalHash | None#
- uhash_randomize()#
- undo_fix_uhash()#
- undo_randomize()#
- property workflow_id: str | None#