Available features in the public API

DistributedWorkflows.application_configMethod
application_config(port::String, impl::String, fname::String)

Convenience constructor for configuring a workflow application with a single transition.

Arguments

  • ports::String: Ports to configure for the workflow transition.
  • impl::String: Julia file containing the implementation called by the workflow transition.
  • fnames::String: Function name to be executed by the workflow transition.

See also Workflow_PetriNet, generate_workflow, compile_workflow.

source
DistributedWorkflows.application_configMethod
application_config(ports::Vector{String}, impl::String, fnames::Vector{String})

Convenience constructor for configuring a workflow application with multiple transitions sourcing their implementation details from the same file.

Arguments

  • ports::Vector{String}: List of ports to configure for the workflow transitions.
  • impl::String: Julia file containing the implementations called by the workflow transitions.
  • fnames::Vector{String}: List of function names to be executed by the workflow transitions.

See also Workflow_PetriNet, generate_workflow, compile_workflow.

source
DistributedWorkflows.application_configMethod
application_config(ports::Vector{String}, impl::Vector{String}, fnames::Vector{String})

Constructor for configuring a workflow application with multiple transitions.

Arguments

  • ports::Vector{String}: List of ports to configure for the workflow transitions.
  • impl::Vector{String}: List of julia files containing the implementations called by the workflow transitions.
  • fnames::Vector{String}: List of function names to be executed by the workflow transitions.

See also Workflow_PetriNet, generate_workflow, compile_workflow.

source
DistributedWorkflows.clientMethod
client(workers::Int, nodefile::String, rif_strategy::String, log_host::String, log_port::Int)

Configures and starts a client setting up the workflow execution infrastructure and connects to a logging service. The nodefile will be automatically populated with the local host name if it doesn't exist in the given location or the rif_strategy is local.

Arguments

  • workers::Int: Number of workers launched per node.
  • nodefile::String: Location of the nodefile.
  • rif_strategy::String: Launch mode of the workflow infrastructure. Accepts ssh for distributing the workers across multiple nodes or local for running on the localhost only.
  • log_host::String: Host of the logging service.
  • log_port::Int : Port the logging service is listening on.

See also Workflow_PetriNet, generate_workflow, compile_workflow.

source
DistributedWorkflows.clientMethod
client(workers::Int, nodefile::String, rif_strategy::String)

Configures and starts a client setting up the workflow execution infrastructure. The nodefile will be automatically populated with the local host name if it doesn't exist in the given location or the rif_strategy is local.

Arguments

  • workers::Int: Number of workers launched per node.
  • nodefile::String: Location of the nodefile.
  • rif_strategy::String: Launch mode of the workflow infrastructure. Accepts ssh for distributing the workers across multiple nodes or local for running on the localhost only.

See also Workflow_PetriNet, generate_workflow, compile_workflow.

source
DistributedWorkflows.workflow_configMethod
workflow_config(workflow::String, output_dir::String, app_config::Application_config_many)

Configures a workflow for execution by a client instance.

Arguments

  • workflow::String: Name of the workflow.
  • output_dir::String: Location to store any output data generated during the workflow execution.
  • app_config::Application_config_many: Application configurations for the workflow exeuction.

See also Workflow_PetriNet, generate_workflow, compile_workflow.

source
DistributedWorkflows.workflow_configMethod
workflow_config(workflow::String, output_dir::String, app_config::Application_config)

Configures a workflow for execution by a client instance.

Arguments

  • workflow::String: Name of the workflow.
  • output_dir::String: Location to store any output data generated during the workflow execution.
  • app_config::Application_config: Application configuration for the workflow exeuction.

See also Workflow_PetriNet, generate_workflow, compile_workflow.

source
DistributedWorkflows.workflow_configMethod
workflow_config(workflow::String, output_dir::String, app_config::Vector{Application_config})

Configures a workflow for execution by a client instance.

Arguments

  • workflow::String: Name of the workflow.
  • output_dir::String: Location to store any output data generated during the workflow execution.
  • app_config::Vector{Application_config}: List of application configurations for the workflow exeuction.

See also Workflow_PetriNet, generate_workflow, compile_workflow.

source