Skip to main content
Ctrl+K

ewokscore 0.13.1 documentation

  • Tutorials
  • Workflow definition
  • How-to Guides
  • Workflow implementation
  • API documentation
  • gitlab
  • pypi
  • Tutorials
  • Workflow definition
  • How-to Guides
  • Workflow implementation
  • API documentation
  • gitlab
  • pypi

Section Navigation

  • ewokscore
    • ewokscore.bindings
      • ewokscore.bindings.convert_graph
      • ewokscore.bindings.execute_graph
      • ewokscore.bindings.graph_is_supported
      • ewokscore.bindings.load_graph
      • ewokscore.bindings.save_graph
    • ewokscore.cliutils
      • ewokscore.cliutils.add_convert_parameters
      • ewokscore.cliutils.add_execute_parameters
      • ewokscore.cliutils.apply_convert_parameters
      • ewokscore.cliutils.apply_execute_parameters
      • ewokscore.cliutils.cliconvertutils
        • ewokscore.cliutils.cliconvertutils.add_convert_parameters
        • ewokscore.cliutils.cliconvertutils.apply_convert_parameters
      • ewokscore.cliutils.cliexecuteutils
        • ewokscore.cliutils.cliexecuteutils.add_execute_parameters
        • ewokscore.cliutils.cliexecuteutils.apply_execute_parameters
      • ewokscore.cliutils.clilogutils
        • ewokscore.cliutils.clilogutils.add_log_parameters
        • ewokscore.cliutils.clilogutils.apply_log_parameters
      • ewokscore.cliutils.utils
        • ewokscore.cliutils.utils.parse_option
        • ewokscore.cliutils.utils.parse_parameter
        • ewokscore.cliutils.utils.parse_value
        • ewokscore.cliutils.utils.parse_workflow
    • ewokscore.dynamictask
      • ewokscore.dynamictask.get_dynamically_task_class
      • ewokscore.dynamictask.get_task_class_generator
    • ewokscore.events
      • ewokscore.events.contexts
        • ewokscore.events.contexts.job_context
        • ewokscore.events.contexts.job_decorator
        • ewokscore.events.contexts.node_context
        • ewokscore.events.contexts.workflow_context
      • ewokscore.events.global_state
        • ewokscore.events.global_state.add_handler
        • ewokscore.events.global_state.cleanup
        • ewokscore.events.global_state.remove_handler
        • ewokscore.events.global_state.send
      • ewokscore.events.handlers
        • ewokscore.events.handlers.base
        • ewokscore.events.handlers.sqlite3
      • ewokscore.events.initialize_events
        • ewokscore.events.initialize_events.init_job
        • ewokscore.events.initialize_events.init_node
        • ewokscore.events.initialize_events.init_workflow
        • ewokscore.events.initialize_events.set_environment
      • ewokscore.events.send_events
        • ewokscore.events.send_events.send_job_event
        • ewokscore.events.send_events.send_task_event
        • ewokscore.events.send_events.send_workflow_event
        • ewokscore.events.send_events.timestamp
    • ewokscore.graph
      • ewokscore.graph.analysis
        • ewokscore.graph.analysis.end_nodes
        • ewokscore.graph.analysis.graph_has_conditional_links
        • ewokscore.graph.analysis.graph_is_cyclic
        • ewokscore.graph.analysis.has_required_predecessors
        • ewokscore.graph.analysis.has_required_static_inputs
        • ewokscore.graph.analysis.iter_downstream_nodes
        • ewokscore.graph.analysis.iter_upstream_nodes
        • ewokscore.graph.analysis.iterator_has_items
        • ewokscore.graph.analysis.link_has_conditions
        • ewokscore.graph.analysis.link_has_on_error
        • ewokscore.graph.analysis.link_has_required
        • ewokscore.graph.analysis.link_is_conditional
        • ewokscore.graph.analysis.link_is_required
        • ewokscore.graph.analysis.node_ancestors
        • ewokscore.graph.analysis.node_condition_values
        • ewokscore.graph.analysis.node_descendants
        • ewokscore.graph.analysis.node_has_ancestors
        • ewokscore.graph.analysis.node_has_descendants
        • ewokscore.graph.analysis.node_has_error_handlers
        • ewokscore.graph.analysis.node_has_noncovered_conditions
        • ewokscore.graph.analysis.node_has_predecessors
        • ewokscore.graph.analysis.node_has_successors
        • ewokscore.graph.analysis.node_is_end_node
        • ewokscore.graph.analysis.node_is_pure_end_node
        • ewokscore.graph.analysis.node_is_required
        • ewokscore.graph.analysis.node_is_start_node
        • ewokscore.graph.analysis.node_predecessors
        • ewokscore.graph.analysis.node_pure_descendants
        • ewokscore.graph.analysis.node_successors
        • ewokscore.graph.analysis.required_predecessors
        • ewokscore.graph.analysis.start_nodes
        • ewokscore.graph.analysis.topological_sort
      • ewokscore.graph.compare
        • ewokscore.graph.compare.graphs_are_equal
      • ewokscore.graph.error_handlers
        • ewokscore.graph.error_handlers.connect_default_error_handlers
      • ewokscore.graph.execute
        • ewokscore.graph.execute.sequential
      • ewokscore.graph.graph_io
        • ewokscore.graph.graph_io.add_output_values
        • ewokscore.graph.graph_io.extract_output_values
        • ewokscore.graph.graph_io.iter_node_ids
        • ewokscore.graph.graph_io.parse_inputs
        • ewokscore.graph.graph_io.parse_outputs
        • ewokscore.graph.graph_io.update_default_inputs
      • ewokscore.graph.models
      • ewokscore.graph.multigraph
        • ewokscore.graph.multigraph.flatten_multigraph
      • ewokscore.graph.schema
        • ewokscore.graph.schema.get_versions
        • ewokscore.graph.schema.normalize_schema_version
        • ewokscore.graph.schema.update_graph_schema
        • ewokscore.graph.schema.GraphSchemaError
        • ewokscore.graph.schema.metadata
        • ewokscore.graph.schema.update
      • ewokscore.graph.serialize
        • ewokscore.graph.serialize.dump
        • ewokscore.graph.serialize.ewoks_jsonload_hook
        • ewokscore.graph.serialize.json_load
        • ewokscore.graph.serialize.load
        • ewokscore.graph.serialize.GraphRepresentation
      • ewokscore.graph.subgraph
        • ewokscore.graph.subgraph.add_subgraph_links
        • ewokscore.graph.subgraph.extract_graph_nodes
      • ewokscore.graph.taskgraph
        • ewokscore.graph.taskgraph.get_subgraphs
        • ewokscore.graph.taskgraph.load_graph
        • ewokscore.graph.taskgraph.merge_graphs
        • ewokscore.graph.taskgraph.node_has_links
        • ewokscore.graph.taskgraph.TaskGraph
      • ewokscore.graph.validate
        • ewokscore.graph.validate.validate_graph
    • ewokscore.hashing
      • ewokscore.hashing.classhashdata
      • ewokscore.hashing.multitype_sorted
      • ewokscore.hashing.uhash
      • ewokscore.hashing.HasUhash
      • ewokscore.hashing.UniversalHash
      • ewokscore.hashing.UniversalHashable
    • ewokscore.inittask
      • ewokscore.inittask.add_dynamic_inputs
      • ewokscore.inittask.get_task_class
      • ewokscore.inittask.instantiate_task
      • ewokscore.inittask.raise_task_error
      • ewokscore.inittask.task_executable
      • ewokscore.inittask.task_executable_info
      • ewokscore.inittask.validate_task_executable
    • ewokscore.methodtask
      • ewokscore.methodtask.MethodExecutorTask
    • ewokscore.missing_data
      • ewokscore.missing_data.is_missing_data
      • ewokscore.missing_data.MissingData
    • ewokscore.node
      • ewokscore.node.flatten_node_id
      • ewokscore.node.get_node_id
      • ewokscore.node.get_node_label
      • ewokscore.node.get_task_identifier
      • ewokscore.node.get_varinfo
      • ewokscore.node.node_id_as_string
      • ewokscore.node.node_id_from_json
    • ewokscore.notebooktask
      • ewokscore.notebooktask.NotebookExecutorTask
    • ewokscore.persistence
      • ewokscore.persistence.atomic
        • ewokscore.persistence.atomic.append_hdf5
        • ewokscore.persistence.atomic.atomic_create_path
        • ewokscore.persistence.atomic.atomic_write
        • ewokscore.persistence.atomic.atomic_write_hdf5
        • ewokscore.persistence.atomic.nonexisting_tmp_file
        • ewokscore.persistence.atomic.random_string
      • ewokscore.persistence.file
        • ewokscore.persistence.file.FileProxy
      • ewokscore.persistence.json
        • ewokscore.persistence.json.modify_dict
        • ewokscore.persistence.json.JsonProxy
      • ewokscore.persistence.nexus
        • ewokscore.persistence.nexus.h5_item_exists
        • ewokscore.persistence.nexus.NexusProxy
      • ewokscore.persistence.proxy
        • ewokscore.persistence.proxy.DataProxy
        • ewokscore.persistence.proxy.DataUri
        • ewokscore.persistence.proxy.PersistenceError
        • ewokscore.persistence.proxy.UriNotFoundError
      • ewokscore.persistence.uri
        • ewokscore.persistence.uri.join_uri
        • ewokscore.persistence.uri.parse_query
        • ewokscore.persistence.uri.parse_uri
        • ewokscore.persistence.uri.path_from_uri
        • ewokscore.persistence.uri.uri_as_string
    • ewokscore.ppftasks
      • ewokscore.ppftasks.PpfMethodExecutorTask
      • ewokscore.ppftasks.PpfPortTask
    • ewokscore.progress
      • ewokscore.progress.BasePercentageProgress
      • ewokscore.progress.BaseProgress
      • ewokscore.progress.TextProgress
    • ewokscore.registration
      • ewokscore.registration.Registered
    • ewokscore.scripttask
      • ewokscore.scripttask.ScriptExecutorTask
    • ewokscore.task
      • ewokscore.task.Task
      • ewokscore.task.TaskInputError
    • ewokscore.task_discovery
      • ewokscore.task_discovery.discover_all_tasks
      • ewokscore.task_discovery.discover_tasks_from_modules
      • ewokscore.task_discovery.iter_discover_all_tasks
      • ewokscore.task_discovery.iter_discover_tasks_from_modules
      • ewokscore.task_discovery.iter_entry_points
    • ewokscore.taskwithprogress
      • ewokscore.taskwithprogress.TaskWithProgress
    • ewokscore.tests
      • ewokscore.tests.conftest
        • ewokscore.tests.conftest.testkernel
        • ewokscore.tests.conftest.use_test_schema_versions
        • ewokscore.tests.conftest.varinfo
      • ewokscore.tests.discover_module
        • ewokscore.tests.discover_module.myfunc
        • ewokscore.tests.discover_module.run
        • ewokscore.tests.discover_module.MyTask1
        • ewokscore.tests.discover_module.MyTask2
      • ewokscore.tests.examples
        • ewokscore.tests.examples.graphs
        • ewokscore.tests.examples.loadtest
        • ewokscore.tests.examples.tasks
      • ewokscore.tests.test_cli_utils
        • ewokscore.tests.test_cli_utils.test_cli_convert_workflow
        • ewokscore.tests.test_cli_utils.test_cli_execute_workflow
      • ewokscore.tests.test_default_error_handlers
        • ewokscore.tests.test_default_error_handlers.model1
        • ewokscore.tests.test_default_error_handlers.model2
        • ewokscore.tests.test_default_error_handlers.submodel1
        • ewokscore.tests.test_default_error_handlers.submodel2
        • ewokscore.tests.test_default_error_handlers.subsubmodel1
        • ewokscore.tests.test_default_error_handlers.test_default_error_handlers1
        • ewokscore.tests.test_default_error_handlers.test_default_error_handlers2
      • ewokscore.tests.test_dynamic_tasks
        • ewokscore.tests.test_dynamic_tasks.task_class_generator
        • ewokscore.tests.test_dynamic_tasks.test_task_class_generator
      • ewokscore.tests.test_events
        • ewokscore.tests.test_events.capture_events
        • ewokscore.tests.test_events.test_root_logger
        • ewokscore.tests.test_events.test_task_event
        • ewokscore.tests.test_events.test_workflow_event
      • ewokscore.tests.test_examples
        • ewokscore.tests.test_examples.assert_convert_graph
        • ewokscore.tests.test_examples.test_convert_graph
        • ewokscore.tests.test_examples.test_execute_graph
        • ewokscore.tests.test_examples.test_graph_cyclic
        • ewokscore.tests.test_examples.test_serialize_graph
        • ewokscore.tests.test_examples.test_start_nodes
      • ewokscore.tests.test_execute_graph
        • ewokscore.tests.test_execute_graph.create_graph
        • ewokscore.tests.test_execute_graph.test_execute_graph_inputs
        • ewokscore.tests.test_execute_graph.test_execute_graph_outputs
        • ewokscore.tests.test_execute_graph.SumTask
      • ewokscore.tests.test_graph
        • ewokscore.tests.test_graph.test_required_links
        • ewokscore.tests.test_graph.test_wrong_argument_definitions
      • ewokscore.tests.test_graph_io
        • ewokscore.tests.test_graph_io.graph
        • ewokscore.tests.test_graph_io.test_parse_inputs
        • ewokscore.tests.test_graph_io.test_parse_outputs
        • ewokscore.tests.test_graph_io.test_update_default_inputs
      • ewokscore.tests.test_graph_schema
        • ewokscore.tests.test_graph_schema.assert_latest_version_exists
        • ewokscore.tests.test_graph_schema.assert_load
        • ewokscore.tests.test_graph_schema.test_correct_update_method
        • ewokscore.tests.test_graph_schema.test_error_on_improper_update_methods
        • ewokscore.tests.test_graph_schema.test_graph_version
        • ewokscore.tests.test_graph_schema.test_non_existing_version
        • ewokscore.tests.test_graph_schema.test_update_method_with_exception
      • ewokscore.tests.test_graph_serialize
        • ewokscore.tests.test_graph_serialize.test_graph_discovery_json
        • ewokscore.tests.test_graph_serialize.test_graph_discovery_json_module
        • ewokscore.tests.test_graph_serialize.test_graph_discovery_yaml
      • ewokscore.tests.test_graph_start_end_nodes
        • ewokscore.tests.test_graph_start_end_nodes.test_graph_start_end_nodes
      • ewokscore.tests.test_hashing
        • ewokscore.tests.test_hashing.test_hashable_cleanup_references
        • ewokscore.tests.test_hashing.test_hashing_unique
        • ewokscore.tests.test_hashing.test_pre_uhash
        • ewokscore.tests.test_hashing.test_uhash_fixing
        • ewokscore.tests.test_hashing.test_versioning
      • ewokscore.tests.test_link_is_required
        • ewokscore.tests.test_link_is_required.test_graph_link_is_required_conditions1
        • ewokscore.tests.test_link_is_required.test_graph_link_is_required_conditions2
        • ewokscore.tests.test_link_is_required.test_graph_link_is_required_errors
      • ewokscore.tests.test_method_task
        • ewokscore.tests.test_method_task.mymethod1
        • ewokscore.tests.test_method_task.mymethod2
        • ewokscore.tests.test_method_task.mymethod3
        • ewokscore.tests.test_method_task.myppfmethod
        • ewokscore.tests.test_method_task.test_method_task1
        • ewokscore.tests.test_method_task.test_method_task2
        • ewokscore.tests.test_method_task.test_method_task3
        • ewokscore.tests.test_method_task.test_ppfmethod_task
      • ewokscore.tests.test_notebook_task
        • ewokscore.tests.test_notebook_task.notebook
        • ewokscore.tests.test_notebook_task.test_notebook_task
        • ewokscore.tests.test_notebook_task.test_notebook_task_failure
        • ewokscore.tests.test_notebook_task.test_notebook_task_save
      • ewokscore.tests.test_persistence
        • ewokscore.tests.test_persistence.test_json_proxy_uri
        • ewokscore.tests.test_persistence.test_nexus_proxy_uri
        • ewokscore.tests.test_persistence.test_proxy_dump
      • ewokscore.tests.test_script_task
        • ewokscore.tests.test_script_task.test_command_task
        • ewokscore.tests.test_script_task.test_python_script_task
        • ewokscore.tests.test_script_task.test_shell_script_task
      • ewokscore.tests.test_sub_graph
        • ewokscore.tests.test_sub_graph.myfunc
        • ewokscore.tests.test_sub_graph.test_sub_graph_duplicate_aliases
        • ewokscore.tests.test_sub_graph.test_sub_graph_execute
        • ewokscore.tests.test_sub_graph.test_sub_graph_link_attributes
      • ewokscore.tests.test_sub_graph_serialize
        • ewokscore.tests.test_sub_graph_serialize.graph
        • ewokscore.tests.test_sub_graph_serialize.nonserialized_graph
        • ewokscore.tests.test_sub_graph_serialize.savegraph
        • ewokscore.tests.test_sub_graph_serialize.serialized_graph
        • ewokscore.tests.test_sub_graph_serialize.subgraph
        • ewokscore.tests.test_sub_graph_serialize.subsubgraph
        • ewokscore.tests.test_sub_graph_serialize.subsubsubgraph
        • ewokscore.tests.test_sub_graph_serialize.test_sub_graph_execute
        • ewokscore.tests.test_sub_graph_serialize.test_sub_graph_serialize
      • ewokscore.tests.test_task
        • ewokscore.tests.test_task.assert_storage
        • ewokscore.tests.test_task.expected_task_output_storage
        • ewokscore.tests.test_task.find_files
        • ewokscore.tests.test_task.test_no_public_reserved_names
        • ewokscore.tests.test_task.test_task_cancel
        • ewokscore.tests.test_task.test_task_cleanup_references
        • ewokscore.tests.test_task.test_task_done
        • ewokscore.tests.test_task.test_task_missing_input
        • ewokscore.tests.test_task.test_task_optional_input
        • ewokscore.tests.test_task.test_task_readonly_input
        • ewokscore.tests.test_task.test_task_required_positional_inputs
        • ewokscore.tests.test_task.test_task_storage
        • ewokscore.tests.test_task.test_task_uhash
      • ewokscore.tests.test_task_discovery
        • ewokscore.tests.test_task_discovery.assert_tasks
        • ewokscore.tests.test_task_discovery.test_task_class_discovery
        • ewokscore.tests.test_task_discovery.test_task_discovery
        • ewokscore.tests.test_task_discovery.test_task_method_discovery
        • ewokscore.tests.test_task_discovery.test_task_ppfmethod_discovery
      • ewokscore.tests.test_task_progress
        • ewokscore.tests.test_task_progress.test_no_progress_events
        • ewokscore.tests.test_task_progress.test_no_progress_stdout
        • ewokscore.tests.test_task_progress.test_text_progress_events
        • ewokscore.tests.test_task_progress.test_text_progress_stdout
      • ewokscore.tests.test_uri
        • ewokscore.tests.test_uri.test_abspath_uri
        • ewokscore.tests.test_uri.test_relpath_file_uri
        • ewokscore.tests.test_uri.test_relpath_file_uri_old
      • ewokscore.tests.test_variable
        • ewokscore.tests.test_variable.assert_persisted_variable_value
        • ewokscore.tests.test_variable.assert_persisted_variable_value_status
        • ewokscore.tests.test_variable.assert_variable
        • ewokscore.tests.test_variable.assert_variable_compare
        • ewokscore.tests.test_variable.assert_variable_data_proxy
        • ewokscore.tests.test_variable.assert_variable_no_value
        • ewokscore.tests.test_variable.assert_variable_uhash
        • ewokscore.tests.test_variable.assert_variable_uri
        • ewokscore.tests.test_variable.assert_variable_value
        • ewokscore.tests.test_variable.assert_variable_value_status
        • ewokscore.tests.test_variable.change_value
        • ewokscore.tests.test_variable.test_variable_cleanup_references
        • ewokscore.tests.test_variable.test_variable_container_cleanup_references
        • ewokscore.tests.test_variable.test_variable_container_metadata
        • ewokscore.tests.test_variable.test_variable_container_no_value
        • ewokscore.tests.test_variable.test_variable_container_references
        • ewokscore.tests.test_variable.test_variable_container_reset
        • ewokscore.tests.test_variable.test_variable_container_uri
        • ewokscore.tests.test_variable.test_variable_container_values
        • ewokscore.tests.test_variable.test_variable_container_wrong_value
        • ewokscore.tests.test_variable.test_variable_fixed_uhash
        • ewokscore.tests.test_variable.test_variable_no_value
        • ewokscore.tests.test_variable.test_variable_nonce
        • ewokscore.tests.test_variable.test_variable_none_dump
        • ewokscore.tests.test_variable.test_variable_references
        • ewokscore.tests.test_variable.test_variable_uri
      • ewokscore.tests.test_variable_namespaces
        • ewokscore.tests.test_variable_namespaces.test_missing_namespace
        • ewokscore.tests.test_variable_namespaces.test_namespace
        • ewokscore.tests.test_variable_namespaces.test_readonly_namespace
      • ewokscore.tests.test_workflow_events
        • ewokscore.tests.test_workflow_events.assert_failed_workfow_events
        • ewokscore.tests.test_workflow_events.assert_succesfull_workfow_events
        • ewokscore.tests.test_workflow_events.fetch_events
        • ewokscore.tests.test_workflow_events.run_failed_workfow
        • ewokscore.tests.test_workflow_events.run_succesfull_workfow
        • ewokscore.tests.test_workflow_events.test_failed_workfow
        • ewokscore.tests.test_workflow_events.test_succesfull_workfow
        • ewokscore.tests.test_workflow_events.MyTask
      • ewokscore.tests.utils
        • ewokscore.tests.utils.results
        • ewokscore.tests.utils.show
    • ewokscore.utils
      • ewokscore.utils.dict_merge
    • ewokscore.variable
      • ewokscore.variable.data_proxy_from_varinfo
      • ewokscore.variable.value_from_transfer
      • ewokscore.variable.variable_from_transfer
      • ewokscore.variable.MutableVariableContainer
      • ewokscore.variable.ReadOnlyVariableContainerNamespace
      • ewokscore.variable.Variable
      • ewokscore.variable.VariableContainer
      • ewokscore.variable.VariableContainerMissingNamespace
      • ewokscore.variable.VariableContainerNamespace
      • ewokscore.variable.MissingVariableError
      • ewokscore.variable.ReadOnlyVariableError
  • API documentation
  • ewokscore
  • ewokscore.events
  • ewokscore.events.handlers
  • ewokscore.events.handlers.sqlite3

ewokscore.events.handlers.sqlite3#

Classes

Sqlite3EwoksEventHandler(uri)

previous

ewokscore.events.handlers.base.EwoksEventHandlerMixIn

next

ewokscore.events.handlers.sqlite3.Sqlite3EwoksEventHandler
Show Source

© Copyright 2021-2024, ESRF.

ewokscore 0.13.1