omnipy.shared.protocols.compute.job
Top-level task and flow protocol definitions.
| CLASS | DESCRIPTION |
|---|---|
HasChildJobListArgJobTemplateInit |
Callable initializer protocol for flow templates with child job templates. |
HasFuncArgJobTemplateInit |
Callable initializer protocol for templates that wrap one Python callable. |
HasJobCreator |
Protocol for objects exposing a shared :class: |
IsAnyFlow |
Protocol covering any applied Omnipy flow variant. |
IsAnyFlowTemplate |
|
IsChildJobListArgJob |
|
IsChildJobListArgJobBase |
Protocol for flow-style jobs that own an ordered child-template list. |
IsChildJobListArgJobTemplate |
Template protocol for flows composed from an ordered child-template list. |
IsDagFlow |
Protocol for applied DAG flows. |
IsDagFlowTemplate |
|
IsFlow |
Protocol for applied flows with run-state metadata. |
IsFlowTemplate |
Protocol for flow templates. |
IsFuncArgJob |
Applied-job protocol for callable-backed tasks and flows. |
IsFuncArgJobBase |
Protocol for jobs backed by a Python callable and callable-related options. |
IsFuncArgJobTemplate |
Template protocol for callable-backed tasks and function-style flows. |
IsFuncFlow |
Protocol for callable-backed applied flows. |
IsFuncFlowTemplate |
Protocol for callable-backed flow templates. |
IsJob |
Protocol for an applied job that is ready to execute. |
IsJobBase |
Common protocol shared by job templates and applied jobs. |
IsJobBaseCallable |
Protocol for job objects that expose a normal callable interface. |
IsJobTemplate |
Protocol for a reusable job template with immutable configuration. |
IsLinearFlow |
Protocol for applied linear flows. |
IsLinearFlowTemplate |
Protocol for linear flow templates. |
IsPlainFuncArgJobBase |
Minimal protocol for objects that store and decorate a wrapped callable. |
IsTask |
Protocol for an applied Omnipy task. |
IsTaskTemplate |
Loosely coupled type replacement for the :py:class: |
HasChildJobListArgJobTemplateInit
Bases: Protocol[_JobTemplateT, _CallP, _RetContraT]
flowchart BT
omnipy.shared.protocols.compute.job.HasChildJobListArgJobTemplateInit[HasChildJobListArgJobTemplateInit]
click omnipy.shared.protocols.compute.job.HasChildJobListArgJobTemplateInit href "" "omnipy.shared.protocols.compute.job.HasChildJobListArgJobTemplateInit"
Callable initializer protocol for flow templates with child job templates.
The initializer receives both the coordinating callable and the ordered child templates that make up the flow body.
Source code in src/omnipy/shared/protocols/compute/job.py
HasFuncArgJobTemplateInit
Bases: Protocol[_JobTemplateT, _CallP, _RetContraT]
flowchart BT
omnipy.shared.protocols.compute.job.HasFuncArgJobTemplateInit[HasFuncArgJobTemplateInit]
click omnipy.shared.protocols.compute.job.HasFuncArgJobTemplateInit href "" "omnipy.shared.protocols.compute.job.HasFuncArgJobTemplateInit"
Callable initializer protocol for templates that wrap one Python callable.
This is the decorator-facing constructor shape used by task templates and callable-backed flow templates.
Source code in src/omnipy/shared/protocols/compute/job.py
HasJobCreator
Bases: Protocol
flowchart BT
omnipy.shared.protocols.compute.job.HasJobCreator[HasJobCreator]
click omnipy.shared.protocols.compute.job.HasJobCreator href "" "omnipy.shared.protocols.compute.job.HasJobCreator"
Protocol for objects exposing a shared :class:IsJobCreator instance.
| ATTRIBUTE | DESCRIPTION |
|---|---|
job_creator |
Return the shared creator object backing the job family.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
job_creator
property
job_creator: IsJobCreator
Return the shared creator object backing the job family.
| RETURNS | DESCRIPTION |
|---|---|
IsJobCreator
|
Shared holder for engine, config, and nested-context state.
TYPE:
|
IsAnyFlow
Bases: IsFuncArgJob['IsAnyFlowTemplate[_CallP, _RetCovT]', 'IsAnyFlow[_CallP, _RetCovT]', _CallP, _RetCovT], IsFlow, Protocol[_CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsAnyFlow[IsAnyFlow]
omnipy.shared.protocols.compute.job.IsFuncArgJob[IsFuncArgJob]
omnipy.shared.protocols.compute.job.IsJob[IsJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFlow[IsFlow]
omnipy.shared.protocols.compute.job.IsFuncArgJob --> omnipy.shared.protocols.compute.job.IsAnyFlow
omnipy.shared.protocols.compute.job.IsJob --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJob
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsFlow --> omnipy.shared.protocols.compute.job.IsAnyFlow
click omnipy.shared.protocols.compute.job.IsAnyFlow href "" "omnipy.shared.protocols.compute.job.IsAnyFlow"
click omnipy.shared.protocols.compute.job.IsFuncArgJob href "" "omnipy.shared.protocols.compute.job.IsFuncArgJob"
click omnipy.shared.protocols.compute.job.IsJob href "" "omnipy.shared.protocols.compute.job.IsJob"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
click omnipy.shared.protocols.compute.job.IsFlow href "" "omnipy.shared.protocols.compute.job.IsFlow"
Protocol covering any applied Omnipy flow variant.
This union-style flow contract is useful where task, linear-flow, DAG-flow, and function-flow implementations are all accepted.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
create_job |
Create an applied job instance from the concrete job class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
revise |
Return a template reconstructed from this applied job. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
flow_context |
Return a context manager that enters and exits the shared flow context.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
time_of_cur_toplevel_flow_run |
Return the start time of the active top-level flow run, if any.
TYPE:
|
time_of_last_run |
Return the timestamp captured for the most recent top-level flow run.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
flow_context
property
flow_context: IsNestedContext
Return a context manager that enters and exits the shared flow context.
| RETURNS | DESCRIPTION |
|---|---|
IsNestedContext
|
Context manager that tracks top-level flow execution state.
TYPE:
|
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
time_of_cur_toplevel_flow_run
property
Return the start time of the active top-level flow run, if any.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp for the current outermost flow run, or |
time_of_last_run
property
Return the timestamp captured for the most recent top-level flow run.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp from the latest top-level flow run, or |
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
create_job
classmethod
Create an applied job instance from the concrete job class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
New applied job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
revise
Return a template reconstructed from this applied job.
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Template carrying the current job configuration.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsAnyFlowTemplate
Bases: IsFuncArgJobTemplate['IsAnyFlowTemplate[_CallP, _RetCovT]', 'IsAnyFlow[_CallP, _RetCovT]', _CallP, _RetCovT], IsFlowTemplate, Protocol[_CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsAnyFlowTemplate[IsAnyFlowTemplate]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate[IsFuncArgJobTemplate]
omnipy.shared.protocols.compute.job.IsJobTemplate[IsJobTemplate]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFlowTemplate[IsFlowTemplate]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate --> omnipy.shared.protocols.compute.job.IsAnyFlowTemplate
omnipy.shared.protocols.compute.job.IsJobTemplate --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJobTemplate
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsFlowTemplate --> omnipy.shared.protocols.compute.job.IsAnyFlowTemplate
click omnipy.shared.protocols.compute.job.IsAnyFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsAnyFlowTemplate"
click omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobTemplate href "" "omnipy.shared.protocols.compute.job.IsJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
click omnipy.shared.protocols.compute.job.IsFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsFlowTemplate"
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
apply |
Create an applied job from this template without executing it. |
create_job_template |
Create a job template instance from the concrete template class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
refine |
Return a template with updated callable-configuration settings. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
run |
Apply the template and execute the resulting job immediately. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
apply
Create an applied job from this template without executing it.
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
Applied job instance ready to be called.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
create_job_template
classmethod
Create a job template instance from the concrete template class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
New job template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
refine
refine(
*args: Any,
update: bool = True,
name: str | None = None,
iterate_over_data_files: bool = False,
output_dataset_param: str | None = None,
output_dataset_cls: type[IsDataset] | None = None,
auto_async: bool = True,
result_key: str | None = None,
fixed_params: Mapping[str, object] | Iterable[tuple[str, object]] | None = None,
param_key_map: Mapping[str, str] | Iterable[tuple[str, str]] | None = None,
persist_outputs: PersistOutputsOptions.Literals = PersistOutputsOptions.FOLLOW_CONFIG,
restore_outputs: RestoreOutputsOptions.Literals = RestoreOutputsOptions.FOLLOW_CONFIG,
**kwargs: object,
) -> _JobTemplateT
Return a template with updated callable-configuration settings.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor overrides for the template.
TYPE:
|
update
|
Whether omitted values should be inherited from the current template.
TYPE:
|
name
|
Optional replacement display name.
TYPE:
|
iterate_over_data_files
|
Whether dataset inputs should be processed item-wise.
TYPE:
|
output_dataset_param
|
Optional name of an explicit output-dataset parameter.
TYPE:
|
output_dataset_cls
|
Optional dataset class to use for iterated outputs.
TYPE:
|
auto_async
|
Whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
result_key
|
Optional key used to wrap the returned result in a dictionary.
TYPE:
|
fixed_params
|
Keyword arguments fixed onto every job invocation.
TYPE:
|
param_key_map
|
Mapping from external keyword names to callable parameter names.
TYPE:
|
persist_outputs
|
Per-job output-persistence preference.
TYPE:
|
restore_outputs
|
Per-job output-restore preference.
TYPE:
|
**kwargs
|
Additional constructor keyword overrides.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Refined template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
run
Apply the template and execute the resulting job immediately.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional arguments passed to the applied job.
TYPE:
|
**kwargs
|
Keyword arguments passed to the applied job.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_RetCovT
|
Result returned by the applied job.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsChildJobListArgJob
Bases: IsChildJobListArgJobBase, IsFuncArgJob[_JobTemplateT, _JobT, _CallP, _RetCovT], Protocol[_JobTemplateT, _JobT, _CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsChildJobListArgJob[IsChildJobListArgJob]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase[IsChildJobListArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJob[IsFuncArgJob]
omnipy.shared.protocols.compute.job.IsJob[IsJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJob
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJob --> omnipy.shared.protocols.compute.job.IsChildJobListArgJob
omnipy.shared.protocols.compute.job.IsJob --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJob
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJob
click omnipy.shared.protocols.compute.job.IsChildJobListArgJob href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJob"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase"
click omnipy.shared.protocols.compute.job.IsFuncArgJob href "" "omnipy.shared.protocols.compute.job.IsFuncArgJob"
click omnipy.shared.protocols.compute.job.IsJob href "" "omnipy.shared.protocols.compute.job.IsJob"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
create_job |
Create an applied job instance from the concrete job class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
revise |
Return a template reconstructed from this applied job. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
child_job_templates |
Return the child-job templates owned by the flow template.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
time_of_cur_toplevel_flow_run |
Return the start time of the active top-level flow run, if any.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
child_job_templates
property
child_job_templates: tuple[IsFuncArgJobTemplate, ...]
Return the child-job templates owned by the flow template.
| RETURNS | DESCRIPTION |
|---|---|
tuple[IsFuncArgJobTemplate, ...]
|
tuple[IsFuncArgJobTemplate, ...]: Ordered child-job templates. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
time_of_cur_toplevel_flow_run
property
Return the start time of the active top-level flow run, if any.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp for the current outermost flow run, or |
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
create_job
classmethod
Create an applied job instance from the concrete job class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
New applied job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
revise
Return a template reconstructed from this applied job.
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Template carrying the current job configuration.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsChildJobListArgJobBase
Bases: IsFuncArgJobBase, Protocol
flowchart BT
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase[IsChildJobListArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
Protocol for flow-style jobs that own an ordered child-template list.
The child templates define the nested jobs a flow applies or orchestrates in addition to its own callable-backed configuration.
| METHOD | DESCRIPTION |
|---|---|
get_bound_args |
Bind arguments to the job callable signature. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
child_job_templates |
Return the child-job templates owned by the flow template.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
child_job_templates
property
child_job_templates: tuple[IsFuncArgJobTemplate, ...]
Return the child-job templates owned by the flow template.
| RETURNS | DESCRIPTION |
|---|---|
tuple[IsFuncArgJobTemplate, ...]
|
tuple[IsFuncArgJobTemplate, ...]: Ordered child-job templates. |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
IsChildJobListArgJobTemplate
Bases: IsFuncArgJobTemplate[_JobTemplateT, _JobT, _CallP, _RetCovT], IsChildJobListArgJobBase, Protocol[_JobTemplateT, _JobT, _CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate[IsChildJobListArgJobTemplate]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate[IsFuncArgJobTemplate]
omnipy.shared.protocols.compute.job.IsJobTemplate[IsJobTemplate]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase[IsChildJobListArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobTemplate --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJobTemplate
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobTemplate href "" "omnipy.shared.protocols.compute.job.IsJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
Template protocol for flows composed from an ordered child-template list.
Refinement can replace the owned child templates while keeping the shared
callable-backed configuration contract from :class:IsFuncArgJobTemplate.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
apply |
Create an applied job from this template without executing it. |
create_job_template |
Create a job template instance from the concrete template class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
refine |
Return a flow template with updated child jobs or callable configuration. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
run |
Apply the template and execute the resulting job immediately. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
child_job_templates |
Return the child-job templates owned by the flow template.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
child_job_templates
property
child_job_templates: tuple[IsFuncArgJobTemplate, ...]
Return the child-job templates owned by the flow template.
| RETURNS | DESCRIPTION |
|---|---|
tuple[IsFuncArgJobTemplate, ...]
|
tuple[IsFuncArgJobTemplate, ...]: Ordered child-job templates. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
apply
Create an applied job from this template without executing it.
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
Applied job instance ready to be called.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
create_job_template
classmethod
Create a job template instance from the concrete template class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
New job template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
refine
refine(
*child_job_templates: IsFuncArgJobTemplate,
update: bool = True,
name: str | None = None,
iterate_over_data_files: bool = False,
output_dataset_param: str | None = None,
output_dataset_cls: type[IsDataset] | None = None,
auto_async: bool = True,
result_key: str | None = None,
fixed_params: Mapping[str, object] | Iterable[tuple[str, object]] | None = None,
param_key_map: Mapping[str, str] | Iterable[tuple[str, str]] | None = None,
persist_outputs: PersistOutputsOptions.Literals = PersistOutputsOptions.FOLLOW_CONFIG,
restore_outputs: RestoreOutputsOptions.Literals = RestoreOutputsOptions.FOLLOW_CONFIG,
**kwargs: object,
) -> _JobTemplateT
Return a flow template with updated child jobs or callable configuration.
| PARAMETER | DESCRIPTION |
|---|---|
*child_job_templates
|
Replacement ordered child-job templates.
TYPE:
|
update
|
Whether omitted values should be inherited from the current template.
TYPE:
|
name
|
Optional replacement display name.
TYPE:
|
iterate_over_data_files
|
Whether dataset inputs should be processed item-wise.
TYPE:
|
output_dataset_param
|
Optional name of an explicit output-dataset parameter.
TYPE:
|
output_dataset_cls
|
Optional dataset class to use for iterated outputs.
TYPE:
|
auto_async
|
Whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
result_key
|
Optional key used to wrap the returned result in a dictionary.
TYPE:
|
fixed_params
|
Keyword arguments fixed onto every job invocation.
TYPE:
|
param_key_map
|
Mapping from external keyword names to callable parameter names.
TYPE:
|
persist_outputs
|
Per-job output-persistence preference.
TYPE:
|
restore_outputs
|
Per-job output-restore preference.
TYPE:
|
**kwargs
|
Additional constructor keyword overrides.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Refined template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
run
Apply the template and execute the resulting job immediately.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional arguments passed to the applied job.
TYPE:
|
**kwargs
|
Keyword arguments passed to the applied job.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_RetCovT
|
Result returned by the applied job.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsDagFlow
Bases: IsChildJobListArgJob['IsDagFlowTemplate[_CallP, _RetCovT]', 'IsDagFlow[_CallP, _RetCovT]', _CallP, _RetCovT], IsFlow, Protocol[_CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsDagFlow[IsDagFlow]
omnipy.shared.protocols.compute.job.IsChildJobListArgJob[IsChildJobListArgJob]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase[IsChildJobListArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJob[IsFuncArgJob]
omnipy.shared.protocols.compute.job.IsJob[IsJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFlow[IsFlow]
omnipy.shared.protocols.compute.job.IsChildJobListArgJob --> omnipy.shared.protocols.compute.job.IsDagFlow
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJob
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJob --> omnipy.shared.protocols.compute.job.IsChildJobListArgJob
omnipy.shared.protocols.compute.job.IsJob --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJob
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsFlow --> omnipy.shared.protocols.compute.job.IsDagFlow
click omnipy.shared.protocols.compute.job.IsDagFlow href "" "omnipy.shared.protocols.compute.job.IsDagFlow"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJob href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJob"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase"
click omnipy.shared.protocols.compute.job.IsFuncArgJob href "" "omnipy.shared.protocols.compute.job.IsFuncArgJob"
click omnipy.shared.protocols.compute.job.IsJob href "" "omnipy.shared.protocols.compute.job.IsJob"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
click omnipy.shared.protocols.compute.job.IsFlow href "" "omnipy.shared.protocols.compute.job.IsFlow"
Protocol for applied DAG flows.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
create_job |
Create an applied job instance from the concrete job class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
revise |
Return a template reconstructed from this applied job. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
child_job_templates |
Return the child-job templates owned by the flow template.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
flow_context |
Return a context manager that enters and exits the shared flow context.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
time_of_cur_toplevel_flow_run |
Return the start time of the active top-level flow run, if any.
TYPE:
|
time_of_last_run |
Return the timestamp captured for the most recent top-level flow run.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
child_job_templates
property
child_job_templates: tuple[IsFuncArgJobTemplate, ...]
Return the child-job templates owned by the flow template.
| RETURNS | DESCRIPTION |
|---|---|
tuple[IsFuncArgJobTemplate, ...]
|
tuple[IsFuncArgJobTemplate, ...]: Ordered child-job templates. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
flow_context
property
flow_context: IsNestedContext
Return a context manager that enters and exits the shared flow context.
| RETURNS | DESCRIPTION |
|---|---|
IsNestedContext
|
Context manager that tracks top-level flow execution state.
TYPE:
|
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
time_of_cur_toplevel_flow_run
property
Return the start time of the active top-level flow run, if any.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp for the current outermost flow run, or |
time_of_last_run
property
Return the timestamp captured for the most recent top-level flow run.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp from the latest top-level flow run, or |
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
create_job
classmethod
Create an applied job instance from the concrete job class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
New applied job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
revise
Return a template reconstructed from this applied job.
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Template carrying the current job configuration.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsDagFlowTemplate
Bases: IsChildJobListArgJobTemplate['IsDagFlowTemplate[_CallP, _RetCovT]', 'IsDagFlow[_CallP, _RetCovT]', _CallP, _RetCovT], IsFlowTemplate, Protocol[_CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsDagFlowTemplate[IsDagFlowTemplate]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate[IsChildJobListArgJobTemplate]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate[IsFuncArgJobTemplate]
omnipy.shared.protocols.compute.job.IsJobTemplate[IsJobTemplate]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase[IsChildJobListArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFlowTemplate[IsFlowTemplate]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate --> omnipy.shared.protocols.compute.job.IsDagFlowTemplate
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobTemplate --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJobTemplate
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase
omnipy.shared.protocols.compute.job.IsFlowTemplate --> omnipy.shared.protocols.compute.job.IsDagFlowTemplate
click omnipy.shared.protocols.compute.job.IsDagFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsDagFlowTemplate"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobTemplate href "" "omnipy.shared.protocols.compute.job.IsJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
click omnipy.shared.protocols.compute.job.IsFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsFlowTemplate"
-
Reference
Code reference
omnipy
compute
flowdag_flow_template_as_callable_decorator
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
apply |
Create an applied job from this template without executing it. |
create_job_template |
Create a job template instance from the concrete template class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
refine |
Return a flow template with updated child jobs or callable configuration. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
run |
Apply the template and execute the resulting job immediately. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
child_job_templates |
Return the child-job templates owned by the flow template.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
child_job_templates
property
child_job_templates: tuple[IsFuncArgJobTemplate, ...]
Return the child-job templates owned by the flow template.
| RETURNS | DESCRIPTION |
|---|---|
tuple[IsFuncArgJobTemplate, ...]
|
tuple[IsFuncArgJobTemplate, ...]: Ordered child-job templates. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
apply
Create an applied job from this template without executing it.
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
Applied job instance ready to be called.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
create_job_template
classmethod
Create a job template instance from the concrete template class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
New job template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
refine
refine(
*child_job_templates: IsFuncArgJobTemplate,
update: bool = True,
name: str | None = None,
iterate_over_data_files: bool = False,
output_dataset_param: str | None = None,
output_dataset_cls: type[IsDataset] | None = None,
auto_async: bool = True,
result_key: str | None = None,
fixed_params: Mapping[str, object] | Iterable[tuple[str, object]] | None = None,
param_key_map: Mapping[str, str] | Iterable[tuple[str, str]] | None = None,
persist_outputs: PersistOutputsOptions.Literals = PersistOutputsOptions.FOLLOW_CONFIG,
restore_outputs: RestoreOutputsOptions.Literals = RestoreOutputsOptions.FOLLOW_CONFIG,
**kwargs: object,
) -> _JobTemplateT
Return a flow template with updated child jobs or callable configuration.
| PARAMETER | DESCRIPTION |
|---|---|
*child_job_templates
|
Replacement ordered child-job templates.
TYPE:
|
update
|
Whether omitted values should be inherited from the current template.
TYPE:
|
name
|
Optional replacement display name.
TYPE:
|
iterate_over_data_files
|
Whether dataset inputs should be processed item-wise.
TYPE:
|
output_dataset_param
|
Optional name of an explicit output-dataset parameter.
TYPE:
|
output_dataset_cls
|
Optional dataset class to use for iterated outputs.
TYPE:
|
auto_async
|
Whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
result_key
|
Optional key used to wrap the returned result in a dictionary.
TYPE:
|
fixed_params
|
Keyword arguments fixed onto every job invocation.
TYPE:
|
param_key_map
|
Mapping from external keyword names to callable parameter names.
TYPE:
|
persist_outputs
|
Per-job output-persistence preference.
TYPE:
|
restore_outputs
|
Per-job output-restore preference.
TYPE:
|
**kwargs
|
Additional constructor keyword overrides.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Refined template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
run
Apply the template and execute the resulting job immediately.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional arguments passed to the applied job.
TYPE:
|
**kwargs
|
Keyword arguments passed to the applied job.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_RetCovT
|
Result returned by the applied job.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsFlow
Bases: Protocol
flowchart BT
omnipy.shared.protocols.compute.job.IsFlow[IsFlow]
click omnipy.shared.protocols.compute.job.IsFlow href "" "omnipy.shared.protocols.compute.job.IsFlow"
Protocol for applied flows with run-state metadata.
| ATTRIBUTE | DESCRIPTION |
|---|---|
flow_context |
Return a context manager that enters and exits the shared flow context.
TYPE:
|
time_of_last_run |
Return the timestamp captured for the most recent top-level flow run.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
flow_context
property
flow_context: IsNestedContext
Return a context manager that enters and exits the shared flow context.
| RETURNS | DESCRIPTION |
|---|---|
IsNestedContext
|
Context manager that tracks top-level flow execution state.
TYPE:
|
IsFlowTemplate
Bases: Protocol
flowchart BT
omnipy.shared.protocols.compute.job.IsFlowTemplate[IsFlowTemplate]
click omnipy.shared.protocols.compute.job.IsFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsFlowTemplate"
Protocol for flow templates.
IsFuncArgJob
Bases: IsJob[_JobTemplateT, _JobT, _CallP, _RetCovT], IsFuncArgJobBase, Protocol[_JobTemplateT, _JobT, _CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsFuncArgJob[IsFuncArgJob]
omnipy.shared.protocols.compute.job.IsJob[IsJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsJob --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJob
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJob
click omnipy.shared.protocols.compute.job.IsFuncArgJob href "" "omnipy.shared.protocols.compute.job.IsFuncArgJob"
click omnipy.shared.protocols.compute.job.IsJob href "" "omnipy.shared.protocols.compute.job.IsJob"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
Applied-job protocol for callable-backed tasks and flows.
- Reference Code reference omnipy
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
create_job |
Create an applied job instance from the concrete job class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
revise |
Return a template reconstructed from this applied job. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
time_of_cur_toplevel_flow_run |
Return the start time of the active top-level flow run, if any.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
time_of_cur_toplevel_flow_run
property
Return the start time of the active top-level flow run, if any.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp for the current outermost flow run, or |
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
create_job
classmethod
Create an applied job instance from the concrete job class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
New applied job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
revise
Return a template reconstructed from this applied job.
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Template carrying the current job configuration.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsFuncArgJobBase
Bases: Protocol
flowchart BT
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
Protocol for jobs backed by a Python callable and callable-related options.
This contract adds signature inspection, dataset-iteration controls, result shaping, and persisted-output settings on top of the base job lifecycle.
| METHOD | DESCRIPTION |
|---|---|
get_bound_args |
Bind arguments to the job callable signature. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 | |
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
IsFuncArgJobTemplate
Bases: IsJobTemplate[_JobTemplateT, _JobT, _CallP, _RetCovT], IsFuncArgJobBase, Protocol[_JobTemplateT, _JobT, _CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate[IsFuncArgJobTemplate]
omnipy.shared.protocols.compute.job.IsJobTemplate[IsJobTemplate]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsJobTemplate --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJobTemplate
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
click omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobTemplate href "" "omnipy.shared.protocols.compute.job.IsJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
Template protocol for callable-backed tasks and function-style flows.
Implementations refine the wrapped callable's execution options without changing the public callable contract seen by template consumers.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
apply |
Create an applied job from this template without executing it. |
create_job_template |
Create a job template instance from the concrete template class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
refine |
Return a template with updated callable-configuration settings. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
run |
Apply the template and execute the resulting job immediately. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
apply
Create an applied job from this template without executing it.
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
Applied job instance ready to be called.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
create_job_template
classmethod
Create a job template instance from the concrete template class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
New job template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
refine
refine(
*args: Any,
update: bool = True,
name: str | None = None,
iterate_over_data_files: bool = False,
output_dataset_param: str | None = None,
output_dataset_cls: type[IsDataset] | None = None,
auto_async: bool = True,
result_key: str | None = None,
fixed_params: Mapping[str, object] | Iterable[tuple[str, object]] | None = None,
param_key_map: Mapping[str, str] | Iterable[tuple[str, str]] | None = None,
persist_outputs: PersistOutputsOptions.Literals = PersistOutputsOptions.FOLLOW_CONFIG,
restore_outputs: RestoreOutputsOptions.Literals = RestoreOutputsOptions.FOLLOW_CONFIG,
**kwargs: object,
) -> _JobTemplateT
Return a template with updated callable-configuration settings.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor overrides for the template.
TYPE:
|
update
|
Whether omitted values should be inherited from the current template.
TYPE:
|
name
|
Optional replacement display name.
TYPE:
|
iterate_over_data_files
|
Whether dataset inputs should be processed item-wise.
TYPE:
|
output_dataset_param
|
Optional name of an explicit output-dataset parameter.
TYPE:
|
output_dataset_cls
|
Optional dataset class to use for iterated outputs.
TYPE:
|
auto_async
|
Whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
result_key
|
Optional key used to wrap the returned result in a dictionary.
TYPE:
|
fixed_params
|
Keyword arguments fixed onto every job invocation.
TYPE:
|
param_key_map
|
Mapping from external keyword names to callable parameter names.
TYPE:
|
persist_outputs
|
Per-job output-persistence preference.
TYPE:
|
restore_outputs
|
Per-job output-restore preference.
TYPE:
|
**kwargs
|
Additional constructor keyword overrides.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Refined template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
run
Apply the template and execute the resulting job immediately.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional arguments passed to the applied job.
TYPE:
|
**kwargs
|
Keyword arguments passed to the applied job.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_RetCovT
|
Result returned by the applied job.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsFuncFlow
Bases: IsFuncArgJob['IsFuncFlowTemplate[_CallP, _RetCovT]', 'IsFuncFlow[_CallP, _RetCovT]', _CallP, _RetCovT], IsFlow, Protocol[_CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsFuncFlow[IsFuncFlow]
omnipy.shared.protocols.compute.job.IsFuncArgJob[IsFuncArgJob]
omnipy.shared.protocols.compute.job.IsJob[IsJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFlow[IsFlow]
omnipy.shared.protocols.compute.job.IsFuncArgJob --> omnipy.shared.protocols.compute.job.IsFuncFlow
omnipy.shared.protocols.compute.job.IsJob --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJob
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsFlow --> omnipy.shared.protocols.compute.job.IsFuncFlow
click omnipy.shared.protocols.compute.job.IsFuncFlow href "" "omnipy.shared.protocols.compute.job.IsFuncFlow"
click omnipy.shared.protocols.compute.job.IsFuncArgJob href "" "omnipy.shared.protocols.compute.job.IsFuncArgJob"
click omnipy.shared.protocols.compute.job.IsJob href "" "omnipy.shared.protocols.compute.job.IsJob"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
click omnipy.shared.protocols.compute.job.IsFlow href "" "omnipy.shared.protocols.compute.job.IsFlow"
Protocol for callable-backed applied flows.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
create_job |
Create an applied job instance from the concrete job class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
revise |
Return a template reconstructed from this applied job. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
flow_context |
Return a context manager that enters and exits the shared flow context.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
time_of_cur_toplevel_flow_run |
Return the start time of the active top-level flow run, if any.
TYPE:
|
time_of_last_run |
Return the timestamp captured for the most recent top-level flow run.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
flow_context
property
flow_context: IsNestedContext
Return a context manager that enters and exits the shared flow context.
| RETURNS | DESCRIPTION |
|---|---|
IsNestedContext
|
Context manager that tracks top-level flow execution state.
TYPE:
|
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
time_of_cur_toplevel_flow_run
property
Return the start time of the active top-level flow run, if any.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp for the current outermost flow run, or |
time_of_last_run
property
Return the timestamp captured for the most recent top-level flow run.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp from the latest top-level flow run, or |
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
create_job
classmethod
Create an applied job instance from the concrete job class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
New applied job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
revise
Return a template reconstructed from this applied job.
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Template carrying the current job configuration.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsFuncFlowTemplate
Bases: IsFuncArgJobTemplate['IsFuncFlowTemplate[_CallP, _RetCovT]', 'IsFuncFlow[_CallP, _RetCovT]', _CallP, _RetCovT], IsFlowTemplate, Protocol[_CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsFuncFlowTemplate[IsFuncFlowTemplate]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate[IsFuncArgJobTemplate]
omnipy.shared.protocols.compute.job.IsJobTemplate[IsJobTemplate]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFlowTemplate[IsFlowTemplate]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate --> omnipy.shared.protocols.compute.job.IsFuncFlowTemplate
omnipy.shared.protocols.compute.job.IsJobTemplate --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJobTemplate
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsFlowTemplate --> omnipy.shared.protocols.compute.job.IsFuncFlowTemplate
click omnipy.shared.protocols.compute.job.IsFuncFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsFuncFlowTemplate"
click omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobTemplate href "" "omnipy.shared.protocols.compute.job.IsJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
click omnipy.shared.protocols.compute.job.IsFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsFlowTemplate"
Protocol for callable-backed flow templates.
-
Reference
Code reference
omnipy
compute
flowfunc_flow_template_as_callable_decorator
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
apply |
Create an applied job from this template without executing it. |
create_job_template |
Create a job template instance from the concrete template class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
refine |
Return a template with updated callable-configuration settings. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
run |
Apply the template and execute the resulting job immediately. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
apply
Create an applied job from this template without executing it.
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
Applied job instance ready to be called.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
create_job_template
classmethod
Create a job template instance from the concrete template class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
New job template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
refine
refine(
*args: Any,
update: bool = True,
name: str | None = None,
iterate_over_data_files: bool = False,
output_dataset_param: str | None = None,
output_dataset_cls: type[IsDataset] | None = None,
auto_async: bool = True,
result_key: str | None = None,
fixed_params: Mapping[str, object] | Iterable[tuple[str, object]] | None = None,
param_key_map: Mapping[str, str] | Iterable[tuple[str, str]] | None = None,
persist_outputs: PersistOutputsOptions.Literals = PersistOutputsOptions.FOLLOW_CONFIG,
restore_outputs: RestoreOutputsOptions.Literals = RestoreOutputsOptions.FOLLOW_CONFIG,
**kwargs: object,
) -> _JobTemplateT
Return a template with updated callable-configuration settings.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor overrides for the template.
TYPE:
|
update
|
Whether omitted values should be inherited from the current template.
TYPE:
|
name
|
Optional replacement display name.
TYPE:
|
iterate_over_data_files
|
Whether dataset inputs should be processed item-wise.
TYPE:
|
output_dataset_param
|
Optional name of an explicit output-dataset parameter.
TYPE:
|
output_dataset_cls
|
Optional dataset class to use for iterated outputs.
TYPE:
|
auto_async
|
Whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
result_key
|
Optional key used to wrap the returned result in a dictionary.
TYPE:
|
fixed_params
|
Keyword arguments fixed onto every job invocation.
TYPE:
|
param_key_map
|
Mapping from external keyword names to callable parameter names.
TYPE:
|
persist_outputs
|
Per-job output-persistence preference.
TYPE:
|
restore_outputs
|
Per-job output-restore preference.
TYPE:
|
**kwargs
|
Additional constructor keyword overrides.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Refined template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
run
Apply the template and execute the resulting job immediately.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional arguments passed to the applied job.
TYPE:
|
**kwargs
|
Keyword arguments passed to the applied job.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_RetCovT
|
Result returned by the applied job.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsJob
Bases: IsJobBaseCallable[_JobTemplateT, _JobT, _CallP, _RetCovT], Protocol[_JobTemplateT, _JobT, _CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsJob[IsJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJob
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
click omnipy.shared.protocols.compute.job.IsJob href "" "omnipy.shared.protocols.compute.job.IsJob"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
Protocol for an applied job that is ready to execute.
Applied jobs carry runtime state such as engine decoration and flow-run timing, and they can be revised back into templates when needed.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
create_job |
Create an applied job instance from the concrete job class. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
revise |
Return a template reconstructed from this applied job. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
time_of_cur_toplevel_flow_run |
Return the start time of the active top-level flow run, if any.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
time_of_cur_toplevel_flow_run
property
Return the start time of the active top-level flow run, if any.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp for the current outermost flow run, or |
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
__init__
create_job
classmethod
Create an applied job instance from the concrete job class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
New applied job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
revise
Return a template reconstructed from this applied job.
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Template carrying the current job configuration.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsJobBase
Bases: CanLog, IsUniquelyNamedJob, Protocol[_JobTemplateT, _JobT, _CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
Common protocol shared by job templates and applied jobs.
Implementations expose stable naming, logging, configuration, and the lifecycle hooks used to move between template, applied-job, and run states.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
__init__
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
IsJobBaseCallable
Bases: IsJobBase[_JobTemplateT, _JobT, _CallP, _RetCovT], Protocol[_JobTemplateT, _JobT, _CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
Protocol for job objects that expose a normal callable interface.
Templates and applied jobs both satisfy this contract, but they may route calls differently depending on whether they are inside a flow context.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
__init__
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
IsJobTemplate
Bases: IsJobBaseCallable[_JobTemplateT, _JobT, _CallP, _RetCovT], Protocol[_JobTemplateT, _JobT, _CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsJobTemplate[IsJobTemplate]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJobTemplate
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
click omnipy.shared.protocols.compute.job.IsJobTemplate href "" "omnipy.shared.protocols.compute.job.IsJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
Protocol for a reusable job template with immutable configuration.
Templates can be created, refined, applied to produce runnable jobs, or run directly through the apply-and-execute convenience path.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
apply |
Create an applied job from this template without executing it. |
create_job_template |
Create a job template instance from the concrete template class. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
run |
Apply the template and execute the resulting job immediately. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
__init__
apply
Create an applied job from this template without executing it.
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
Applied job instance ready to be called.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
create_job_template
classmethod
Create a job template instance from the concrete template class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
New job template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
run
Apply the template and execute the resulting job immediately.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional arguments passed to the applied job.
TYPE:
|
**kwargs
|
Keyword arguments passed to the applied job.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_RetCovT
|
Result returned by the applied job.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsLinearFlow
Bases: IsChildJobListArgJob['IsLinearFlowTemplate[_CallP, _RetCovT]', 'IsLinearFlow[_CallP, _RetCovT]', _CallP, _RetCovT], IsFlow, Protocol[_CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsLinearFlow[IsLinearFlow]
omnipy.shared.protocols.compute.job.IsChildJobListArgJob[IsChildJobListArgJob]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase[IsChildJobListArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJob[IsFuncArgJob]
omnipy.shared.protocols.compute.job.IsJob[IsJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFlow[IsFlow]
omnipy.shared.protocols.compute.job.IsChildJobListArgJob --> omnipy.shared.protocols.compute.job.IsLinearFlow
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJob
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJob --> omnipy.shared.protocols.compute.job.IsChildJobListArgJob
omnipy.shared.protocols.compute.job.IsJob --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJob
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsFlow --> omnipy.shared.protocols.compute.job.IsLinearFlow
click omnipy.shared.protocols.compute.job.IsLinearFlow href "" "omnipy.shared.protocols.compute.job.IsLinearFlow"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJob href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJob"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase"
click omnipy.shared.protocols.compute.job.IsFuncArgJob href "" "omnipy.shared.protocols.compute.job.IsFuncArgJob"
click omnipy.shared.protocols.compute.job.IsJob href "" "omnipy.shared.protocols.compute.job.IsJob"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
click omnipy.shared.protocols.compute.job.IsFlow href "" "omnipy.shared.protocols.compute.job.IsFlow"
Protocol for applied linear flows.
- Reference Code reference
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
create_job |
Create an applied job instance from the concrete job class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
revise |
Return a template reconstructed from this applied job. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
child_job_templates |
Return the child-job templates owned by the flow template.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
flow_context |
Return a context manager that enters and exits the shared flow context.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
time_of_cur_toplevel_flow_run |
Return the start time of the active top-level flow run, if any.
TYPE:
|
time_of_last_run |
Return the timestamp captured for the most recent top-level flow run.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
child_job_templates
property
child_job_templates: tuple[IsFuncArgJobTemplate, ...]
Return the child-job templates owned by the flow template.
| RETURNS | DESCRIPTION |
|---|---|
tuple[IsFuncArgJobTemplate, ...]
|
tuple[IsFuncArgJobTemplate, ...]: Ordered child-job templates. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
flow_context
property
flow_context: IsNestedContext
Return a context manager that enters and exits the shared flow context.
| RETURNS | DESCRIPTION |
|---|---|
IsNestedContext
|
Context manager that tracks top-level flow execution state.
TYPE:
|
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
time_of_cur_toplevel_flow_run
property
Return the start time of the active top-level flow run, if any.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp for the current outermost flow run, or |
time_of_last_run
property
Return the timestamp captured for the most recent top-level flow run.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp from the latest top-level flow run, or |
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
create_job
classmethod
Create an applied job instance from the concrete job class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
New applied job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
revise
Return a template reconstructed from this applied job.
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Template carrying the current job configuration.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsLinearFlowTemplate
Bases: IsChildJobListArgJobTemplate['IsLinearFlowTemplate[_CallP, _RetCovT]', 'IsLinearFlow[_CallP, _RetCovT]', _CallP, _RetCovT], IsFlowTemplate, Protocol[_CallP, _RetCovT]
flowchart BT
omnipy.shared.protocols.compute.job.IsLinearFlowTemplate[IsLinearFlowTemplate]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate[IsChildJobListArgJobTemplate]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate[IsFuncArgJobTemplate]
omnipy.shared.protocols.compute.job.IsJobTemplate[IsJobTemplate]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase[IsChildJobListArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFlowTemplate[IsFlowTemplate]
omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate --> omnipy.shared.protocols.compute.job.IsLinearFlowTemplate
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobTemplate --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJobTemplate
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase
omnipy.shared.protocols.compute.job.IsFlowTemplate --> omnipy.shared.protocols.compute.job.IsLinearFlowTemplate
click omnipy.shared.protocols.compute.job.IsLinearFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsLinearFlowTemplate"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobTemplate href "" "omnipy.shared.protocols.compute.job.IsJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase href "" "omnipy.shared.protocols.compute.job.IsChildJobListArgJobBase"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
click omnipy.shared.protocols.compute.job.IsFlowTemplate href "" "omnipy.shared.protocols.compute.job.IsFlowTemplate"
Protocol for linear flow templates.
- Reference Code reference
-
Reference
Code reference
omnipy
compute
flowlinear_flow_template_as_callable_decorator
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
apply |
Create an applied job from this template without executing it. |
create_job_template |
Create a job template instance from the concrete template class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
refine |
Return a flow template with updated child jobs or callable configuration. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
run |
Apply the template and execute the resulting job immediately. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
child_job_templates |
Return the child-job templates owned by the flow template.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
child_job_templates
property
child_job_templates: tuple[IsFuncArgJobTemplate, ...]
Return the child-job templates owned by the flow template.
| RETURNS | DESCRIPTION |
|---|---|
tuple[IsFuncArgJobTemplate, ...]
|
tuple[IsFuncArgJobTemplate, ...]: Ordered child-job templates. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
apply
Create an applied job from this template without executing it.
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
Applied job instance ready to be called.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
create_job_template
classmethod
Create a job template instance from the concrete template class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
New job template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
refine
refine(
*child_job_templates: IsFuncArgJobTemplate,
update: bool = True,
name: str | None = None,
iterate_over_data_files: bool = False,
output_dataset_param: str | None = None,
output_dataset_cls: type[IsDataset] | None = None,
auto_async: bool = True,
result_key: str | None = None,
fixed_params: Mapping[str, object] | Iterable[tuple[str, object]] | None = None,
param_key_map: Mapping[str, str] | Iterable[tuple[str, str]] | None = None,
persist_outputs: PersistOutputsOptions.Literals = PersistOutputsOptions.FOLLOW_CONFIG,
restore_outputs: RestoreOutputsOptions.Literals = RestoreOutputsOptions.FOLLOW_CONFIG,
**kwargs: object,
) -> _JobTemplateT
Return a flow template with updated child jobs or callable configuration.
| PARAMETER | DESCRIPTION |
|---|---|
*child_job_templates
|
Replacement ordered child-job templates.
TYPE:
|
update
|
Whether omitted values should be inherited from the current template.
TYPE:
|
name
|
Optional replacement display name.
TYPE:
|
iterate_over_data_files
|
Whether dataset inputs should be processed item-wise.
TYPE:
|
output_dataset_param
|
Optional name of an explicit output-dataset parameter.
TYPE:
|
output_dataset_cls
|
Optional dataset class to use for iterated outputs.
TYPE:
|
auto_async
|
Whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
result_key
|
Optional key used to wrap the returned result in a dictionary.
TYPE:
|
fixed_params
|
Keyword arguments fixed onto every job invocation.
TYPE:
|
param_key_map
|
Mapping from external keyword names to callable parameter names.
TYPE:
|
persist_outputs
|
Per-job output-persistence preference.
TYPE:
|
restore_outputs
|
Per-job output-restore preference.
TYPE:
|
**kwargs
|
Additional constructor keyword overrides.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Refined template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
run
Apply the template and execute the resulting job immediately.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional arguments passed to the applied job.
TYPE:
|
**kwargs
|
Keyword arguments passed to the applied job.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_RetCovT
|
Result returned by the applied job.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsPlainFuncArgJobBase
Bases: Protocol
flowchart BT
omnipy.shared.protocols.compute.job.IsPlainFuncArgJobBase[IsPlainFuncArgJobBase]
click omnipy.shared.protocols.compute.job.IsPlainFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsPlainFuncArgJobBase"
Minimal protocol for objects that store and decorate a wrapped callable.
Source code in src/omnipy/shared/protocols/compute/job.py
IsTask
Bases: IsFuncArgJob['IsTaskTemplate[_CallP, _RetT]', 'IsTask[_CallP, _RetT]', _CallP, _RetT], Protocol[_CallP, _RetT]
flowchart BT
omnipy.shared.protocols.compute.job.IsTask[IsTask]
omnipy.shared.protocols.compute.job.IsFuncArgJob[IsFuncArgJob]
omnipy.shared.protocols.compute.job.IsJob[IsJob]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJob --> omnipy.shared.protocols.compute.job.IsTask
omnipy.shared.protocols.compute.job.IsJob --> omnipy.shared.protocols.compute.job.IsFuncArgJob
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJob
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJob
click omnipy.shared.protocols.compute.job.IsTask href "" "omnipy.shared.protocols.compute.job.IsTask"
click omnipy.shared.protocols.compute.job.IsFuncArgJob href "" "omnipy.shared.protocols.compute.job.IsFuncArgJob"
click omnipy.shared.protocols.compute.job.IsJob href "" "omnipy.shared.protocols.compute.job.IsJob"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
Protocol for an applied Omnipy task.
A task represents one runnable callable-backed compute step with no owned child job templates.
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
create_job |
Create an applied job instance from the concrete job class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
revise |
Return a template reconstructed from this applied job. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
time_of_cur_toplevel_flow_run |
Return the start time of the active top-level flow run, if any.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
time_of_cur_toplevel_flow_run
property
Return the start time of the active top-level flow run, if any.
| RETURNS | DESCRIPTION |
|---|---|
datetime | None
|
datetime | None: Timestamp for the current outermost flow run, or |
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
create_job
classmethod
Create an applied job instance from the concrete job class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
New applied job instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
revise
Return a template reconstructed from this applied job.
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Template carrying the current job configuration.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
IsTaskTemplate
Bases: IsFuncArgJobTemplate['IsTaskTemplate[_CallP, _RetT]', 'IsTask[_CallP, _RetT]', _CallP, _RetT], Protocol[_CallP, _RetT]
flowchart BT
omnipy.shared.protocols.compute.job.IsTaskTemplate[IsTaskTemplate]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate[IsFuncArgJobTemplate]
omnipy.shared.protocols.compute.job.IsJobTemplate[IsJobTemplate]
omnipy.shared.protocols.compute.job.IsJobBaseCallable[IsJobBaseCallable]
omnipy.shared.protocols.compute.job.IsJobBase[IsJobBase]
omnipy.shared.protocols.hub.log.CanLog[CanLog]
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob[IsUniquelyNamedJob]
omnipy.shared.protocols.compute.job.IsFuncArgJobBase[IsFuncArgJobBase]
omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate --> omnipy.shared.protocols.compute.job.IsTaskTemplate
omnipy.shared.protocols.compute.job.IsJobTemplate --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
omnipy.shared.protocols.compute.job.IsJobBaseCallable --> omnipy.shared.protocols.compute.job.IsJobTemplate
omnipy.shared.protocols.compute.job.IsJobBase --> omnipy.shared.protocols.compute.job.IsJobBaseCallable
omnipy.shared.protocols.hub.log.CanLog --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob --> omnipy.shared.protocols.compute.job.IsJobBase
omnipy.shared.protocols.compute.job.IsFuncArgJobBase --> omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate
click omnipy.shared.protocols.compute.job.IsTaskTemplate href "" "omnipy.shared.protocols.compute.job.IsTaskTemplate"
click omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobTemplate href "" "omnipy.shared.protocols.compute.job.IsJobTemplate"
click omnipy.shared.protocols.compute.job.IsJobBaseCallable href "" "omnipy.shared.protocols.compute.job.IsJobBaseCallable"
click omnipy.shared.protocols.compute.job.IsJobBase href "" "omnipy.shared.protocols.compute.job.IsJobBase"
click omnipy.shared.protocols.hub.log.CanLog href "" "omnipy.shared.protocols.hub.log.CanLog"
click omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob href "" "omnipy.shared.protocols.compute.mixins.IsUniquelyNamedJob"
click omnipy.shared.protocols.compute.job.IsFuncArgJobBase href "" "omnipy.shared.protocols.compute.job.IsFuncArgJobBase"
Loosely coupled type replacement for the :py:class:~omnipy.compute.task.TaskTemplate class
-
Reference
Code reference
omnipy
compute
tasktask_template_as_callable_decorator
| METHOD | DESCRIPTION |
|---|---|
__init__ |
|
apply |
Create an applied job from this template without executing it. |
create_job_template |
Create a job template instance from the concrete template class. |
get_bound_args |
Bind arguments to the job callable signature. |
log |
Emit a log message, optionally using an explicit event timestamp. |
refine |
Return a template with updated callable-configuration settings. |
regenerate_unique_name |
Regenerate the unique job name from the current base name. |
run |
Apply the template and execute the resulting job immediately. |
| ATTRIBUTE | DESCRIPTION |
|---|---|
auto_async |
Return whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
callable_type |
The effective callable type of the job function.
TYPE:
|
config |
Return the job configuration visible to this instance.
TYPE:
|
engine |
Return the engine associated with this job, if any.
TYPE:
|
fixed_params |
Return parameters that are always supplied when the job callable runs.
TYPE:
|
in_flow_context |
Return whether the job is currently executing inside a flow context.
TYPE:
|
iterate_over_data_files |
Return whether the job should iterate over dataset items automatically.
TYPE:
|
logger |
Return the logger bound to the concrete instance type.
TYPE:
|
name |
Return the configured base name for the job.
TYPE:
|
output_dataset_cls |
Return the dataset class used for iterated outputs, if configured.
TYPE:
|
output_dataset_param |
Return the parameter name used for an explicit output dataset, if any.
TYPE:
|
output_storage_protocol |
Return the configured output-storage protocol preference. |
output_storage_protocol_to_use |
Return the resolved storage protocol used for persisted outputs. |
param_key_map |
Return keyword-name remappings applied before calling the job callable.
TYPE:
|
param_signatures |
Return the inspected parameter signature of the job callable.
TYPE:
|
persist_outputs |
Return the configured per-job output-persistence preference. |
restore_outputs |
Return the configured per-job output-restore preference. |
result_key |
Return the dictionary key used to wrap results, if configured.
TYPE:
|
return_type |
Return the annotated return type of the job callable.
TYPE:
|
unique_name |
Return the generated unique name used to identify the job instance.
TYPE:
|
unique_run_slug |
Return the run-specific slug generated for this job instance.
TYPE:
|
will_persist_outputs |
Return the resolved output-persistence behavior for this run. |
will_restore_outputs |
Return the resolved output-restore behavior for this run. |
Source code in src/omnipy/shared/protocols/compute/job.py
auto_async
property
Return whether coroutine jobs should auto-run outside flow contexts.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
callable_type
property
callable_type: CallableType.Literals
The effective callable type of the job function.
The callable type captures both the synchronous/asynchronous and plain/generator dimensions of the wrapped callable.
| RETURNS | DESCRIPTION |
|---|---|
CallableType.Literals
|
CallableType.Literals: The effective callable type of the job function. |
config
property
config: IsJobConfig
Return the job configuration visible to this instance.
| RETURNS | DESCRIPTION |
|---|---|
IsJobConfig
|
Active job configuration used for runtime behavior.
TYPE:
|
engine
property
engine: IsEngine | None
Return the engine associated with this job, if any.
| RETURNS | DESCRIPTION |
|---|---|
IsEngine | None
|
IsEngine | None: Engine used for decoration and execution, or |
fixed_params
property
Return parameters that are always supplied when the job callable runs.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, object]
|
MappingProxyType[str, object]: Read-only mapping of fixed keyword values. |
in_flow_context
property
Return whether the job is currently executing inside a flow context.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
-
Reference
Code reference
omnipy
engine
run_specTaskRunSpecin_flow_context
iterate_over_data_files
property
Return whether the job should iterate over dataset items automatically.
| RETURNS | DESCRIPTION |
|---|---|
bool
|
TYPE:
|
logger
property
Return the logger bound to the concrete instance type.
| RETURNS | DESCRIPTION |
|---|---|
Logger
|
Logger used by the object for Omnipy log messages.
TYPE:
|
name
property
output_dataset_cls
property
output_dataset_cls: type[IsDataset] | None
Return the dataset class used for iterated outputs, if configured.
| RETURNS | DESCRIPTION |
|---|---|
type[IsDataset] | None
|
type[IsDataset] | None: Output dataset type, or |
output_dataset_param
property
Return the parameter name used for an explicit output dataset, if any.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Output-dataset parameter name, or |
output_storage_protocol
property
output_storage_protocol: OutputStorageProtocolOptions.Literals
Return the configured output-storage protocol preference.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Storage-protocol setting before config fallback. |
output_storage_protocol_to_use
property
output_storage_protocol_to_use: OutputStorageProtocolOptions.Literals
Return the resolved storage protocol used for persisted outputs.
| RETURNS | DESCRIPTION |
|---|---|
OutputStorageProtocolOptions.Literals
|
OutputStorageProtocolOptions.Literals: Effective storage protocol for this run. |
param_key_map
property
Return keyword-name remappings applied before calling the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, str]
|
MappingProxyType[str, str]: Mapping from external keyword names to callable parameter names. |
param_signatures
property
Return the inspected parameter signature of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
MappingProxyType[str, inspect.Parameter]
|
MappingProxyType[str, inspect.Parameter]: Mapping from parameter names to signature entries. |
persist_outputs
property
persist_outputs: PersistOutputsOptions.Literals
Return the configured per-job output-persistence preference.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Persistence setting before config fallback. |
restore_outputs
property
restore_outputs: RestoreOutputsOptions.Literals
Return the configured per-job output-restore preference.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Restore setting before config fallback. |
result_key
property
Return the dictionary key used to wrap results, if configured.
| RETURNS | DESCRIPTION |
|---|---|
str | None
|
str | None: Result wrapper key, or |
return_type
property
Return the annotated return type of the job callable.
| RETURNS | DESCRIPTION |
|---|---|
type
|
Return annotation for the callable.
TYPE:
|
unique_name
property
Return the generated unique name used to identify the job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Unique job identifier suitable for registry lookups and logging.
TYPE:
|
unique_run_slug
property
Return the run-specific slug generated for this job instance.
| RETURNS | DESCRIPTION |
|---|---|
str
|
Short slug used in per-run names and identifiers.
TYPE:
|
will_persist_outputs
property
will_persist_outputs: PersistOutputsOptions.Literals
Return the resolved output-persistence behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
PersistOutputsOptions.Literals
|
PersistOutputsOptions.Literals: Effective persistence behavior after applying config-following rules. |
will_restore_outputs
property
will_restore_outputs: RestoreOutputsOptions.Literals
Return the resolved output-restore behavior for this run.
| RETURNS | DESCRIPTION |
|---|---|
RestoreOutputsOptions.Literals
|
RestoreOutputsOptions.Literals: Effective restore behavior after applying config-following rules. |
__init__
apply
Create an applied job from this template without executing it.
| RETURNS | DESCRIPTION |
|---|---|
_JobT
|
Applied job instance ready to be called.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
create_job_template
classmethod
Create a job template instance from the concrete template class.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor arguments.
TYPE:
|
**kwargs
|
Keyword constructor arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
New job template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
get_bound_args
Bind arguments to the job callable signature.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional call arguments.
TYPE:
|
**kwargs
|
Keyword call arguments.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
inspect.BoundArguments
|
inspect.BoundArguments: Bound arguments with defaults applied. |
Source code in src/omnipy/shared/protocols/compute/job.py
log
Emit a log message, optionally using an explicit event timestamp.
| PARAMETER | DESCRIPTION |
|---|---|
log_msg
|
Message text to send to the logger.
TYPE:
|
level
|
Standard library logging level.
TYPE:
|
datetime_obj
|
Timestamp to attach to the record instead of wall-clock time.
TYPE:
|
Source code in src/omnipy/shared/protocols/hub/log.py
refine
refine(
*args: Any,
update: bool = True,
name: str | None = None,
iterate_over_data_files: bool = False,
output_dataset_param: str | None = None,
output_dataset_cls: type[IsDataset] | None = None,
auto_async: bool = True,
result_key: str | None = None,
fixed_params: Mapping[str, object] | Iterable[tuple[str, object]] | None = None,
param_key_map: Mapping[str, str] | Iterable[tuple[str, str]] | None = None,
persist_outputs: PersistOutputsOptions.Literals = PersistOutputsOptions.FOLLOW_CONFIG,
restore_outputs: RestoreOutputsOptions.Literals = RestoreOutputsOptions.FOLLOW_CONFIG,
**kwargs: object,
) -> _JobTemplateT
Return a template with updated callable-configuration settings.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional constructor overrides for the template.
TYPE:
|
update
|
Whether omitted values should be inherited from the current template.
TYPE:
|
name
|
Optional replacement display name.
TYPE:
|
iterate_over_data_files
|
Whether dataset inputs should be processed item-wise.
TYPE:
|
output_dataset_param
|
Optional name of an explicit output-dataset parameter.
TYPE:
|
output_dataset_cls
|
Optional dataset class to use for iterated outputs.
TYPE:
|
auto_async
|
Whether coroutine jobs should auto-run outside flow contexts.
TYPE:
|
result_key
|
Optional key used to wrap the returned result in a dictionary.
TYPE:
|
fixed_params
|
Keyword arguments fixed onto every job invocation.
TYPE:
|
param_key_map
|
Mapping from external keyword names to callable parameter names.
TYPE:
|
persist_outputs
|
Per-job output-persistence preference.
TYPE:
|
restore_outputs
|
Per-job output-restore preference.
TYPE:
|
**kwargs
|
Additional constructor keyword overrides.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_JobTemplateT
|
Refined template instance.
TYPE:
|
Source code in src/omnipy/shared/protocols/compute/job.py
regenerate_unique_name
Regenerate the unique job name from the current base name.
Updates the stored unique identifier so later registry entries and log messages use a fresh value.
Source code in src/omnipy/shared/protocols/compute/mixins.py
run
Apply the template and execute the resulting job immediately.
| PARAMETER | DESCRIPTION |
|---|---|
*args
|
Positional arguments passed to the applied job.
TYPE:
|
**kwargs
|
Keyword arguments passed to the applied job.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
_RetCovT
|
Result returned by the applied job.
TYPE:
|