spinetoolbox.spine_engine_worker

Contains SpineEngineWorker.

authors

  1. Marin (KTH)

date

14.10.2020

Module Contents

Classes

SpineEngineWorker

param engine_server_address

Address of engine server if any

Functions

_handle_dag_execution_started(project_items)

_handle_node_execution_started(item, direction)

_handle_node_execution_finished(item, direction, state, item_state)

_handle_event_message_arrived(item, filter_id, msg_type, msg_text)

_handle_process_message_arrived(item, filter_id, msg_type, msg_text)

spinetoolbox.spine_engine_worker._handle_dag_execution_started(project_items)[source]
spinetoolbox.spine_engine_worker._handle_node_execution_started(item, direction)[source]
spinetoolbox.spine_engine_worker._handle_node_execution_finished(item, direction, state, item_state)[source]
spinetoolbox.spine_engine_worker._handle_event_message_arrived(item, filter_id, msg_type, msg_text)[source]
spinetoolbox.spine_engine_worker._handle_process_message_arrived(item, filter_id, msg_type, msg_text)[source]
class spinetoolbox.spine_engine_worker.SpineEngineWorker(engine_server_address, engine_data, dag, dag_identifier, project_items)[source]

Bases: PySide2.QtCore.QObject

Parameters

  • engine_server_address (str) – Address of engine server if any

  • engine_data (dict) – engine data

  • dag (DirectedGraphHandler) –

  • dag_identifier (str) –

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

finished[source]
_dag_execution_started[source]
_node_execution_started[source]
_node_execution_finished[source]
_event_message_arrived[source]
_process_message_arrived[source]
property engine_data(self)[source]

Engine data dictionary.

get_engine_data(self)[source]

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(self, engine_data)[source]

Sets the engine data.

Parameters

engine_data (dict) – New data

_handle_event_message_arrived(self, item, filter_id, msg_type, msg_text)[source]
_handle_process_message_arrived(self, item, filter_id, msg_type, msg_text)[source]
stop_engine(self)[source]
engine_final_state(self)[source]
thread(self)[source]
_connect_log_signals(self, silent)[source]
start(self, silent=False)[source]

Connects log signals.

Parameters

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

do_work(self)[source]

Does the work and emits finished when done.

_process_event(self, event_type, data)[source]
_handle_standard_execution_msg(self, msg)[source]
_handle_kernel_execution_msg(self, msg)[source]
_handle_process_msg(self, data)[source]
_do_handle_process_msg(self, item_name, filter_id, msg_type, msg_text)[source]
_handle_event_msg(self, data)[source]
_do_handle_event_msg(self, item_name, filter_id, msg_type, msg_text)[source]
_handle_node_execution_started(self, data)[source]
_do_handle_node_execution_started(self, item_name, direction)[source]

Starts item icon animation when executing forward.

_handle_node_execution_finished(self, data)[source]
_do_handle_node_execution_finished(self, item_name, direction, state, item_state)[source]
clean_up(self)[source]