spinetoolbox.spine_engine_worker

Contains SpineEngineWorker.

Module Contents

Classes

SpineEngineWorker

param engine_data engine data

Functions

_handle_dag_execution_started(project_items)
_handle_node_execution_ignored(project_items)
_handle_node_execution_started(item, direction)
_handle_node_execution_finished(item, direction, ...)
_handle_event_message_arrived(item, filter_id, ...)
_handle_process_message_arrived(item, filter_id, ...)
_handle_prompt_arrived(prompt, engine_mngr[, logger])
_handle_flash_arrived(connection)
_mark_all_items_failed(items)	Fails all project items.

spinetoolbox.spine_engine_worker._handle_dag_execution_started(project_items)

spinetoolbox.spine_engine_worker._handle_node_execution_ignored(project_items)

spinetoolbox.spine_engine_worker._handle_node_execution_started(item, direction)

spinetoolbox.spine_engine_worker._handle_node_execution_finished(item, direction, item_state)

spinetoolbox.spine_engine_worker._handle_event_message_arrived(item, filter_id, msg_type, msg_text)

spinetoolbox.spine_engine_worker._handle_process_message_arrived(item, filter_id, msg_type, msg_text)

spinetoolbox.spine_engine_worker._handle_prompt_arrived(prompt, engine_mngr, logger=None)

spinetoolbox.spine_engine_worker._handle_flash_arrived(connection)

spinetoolbox.spine_engine_worker._mark_all_items_failed(items)

Fails all project items.

Parameters

items (list of ProjectItem) – project items

class spinetoolbox.spine_engine_worker.SpineEngineWorker(engine_data, dag, dag_identifier, project_items, connections, logger, job_id)

Bases: PySide6.QtCore.QObject

Parameters

• engine_data (dict) – engine data

• dag (DirectedGraphHandler) –

• dag_identifier (str) –

• project_items (dict) – mapping from project item name to ProjectItem

• connections (dict) – mapping from jump name to LoggingConnection or LoggingJump

• logger (LoggerInterface) – a logger

• job_id (str) – Job id for remote execution

property job_id

property engine_data

Engine data dictionary.

finished

_mark_items_ignored

_dag_execution_started

_node_execution_started

_node_execution_finished

_event_message_arrived

_process_message_arrived

_prompt_arrived

_flash_arrived

_all_items_failed

get_engine_data()

Returns the engine data. Together with self.set_engine_data() it can be used to modify the workflow after it’s initially created. We use it at the moment for creating Julia sysimages.

Returns

dict

set_engine_data(engine_data)

Sets the engine data.

Parameters

engine_data (dict) – New data

_handle_event_message_arrived_silent(item, filter_id, msg_type, msg_text)

_handle_process_message_arrived_silent(item, filter_id, msg_type, msg_text)

stop_engine()

engine_final_state()

thread()

_connect_log_signals(silent)

start(silent=False)

Connects log signals.

Parameters

silent (bool, optional) – If True, log messages are not forwarded to the loggers but saved in internal dicts.

_included_and_ignored_items()

Returns two lists, where the first one contains project items that are about to be executed and the second one contains project items that are about to be ignored.

_included_items(permitted_items, connections)

Collects a list of project item names that are going to be executed in this DAG based on execution permits and connections in the DAG.

Parameters

• permitted_items (dict) – Mapping of item names to bool. True items have been selected by user for execution.

• connections (list) – Serialized connections

Returns

Project item names

Return type

list

do_work()

Does the work and emits finished when done.

_process_event(event_type, data)

_handle_prompt(prompt)

_handle_flash(flash)

_handle_standard_execution_msg(msg)

_handle_persistent_execution_msg(msg)

_handle_kernel_execution_msg(msg)

_handle_process_msg(data)

_do_handle_process_msg(item_name, filter_id, msg_type, msg_text)

_handle_event_msg(data)

_do_handle_event_msg(item_name, filter_id, msg_type, msg_text)

_handle_node_execution_started(data)

_do_handle_node_execution_started(item_name, direction)

Starts item icon animation when executing forward.

_handle_node_execution_finished(data)

_do_handle_node_execution_finished(item_name, direction, state, item_state)

_handle_server_status_msg(data)

clean_up()