Local Executor

flowdapt.compute.executor.local.LocalExecutor

Bases: Executor

A Local based Executor for running workflows eagerly in a testing environment. Built on top of concurrent.Futures.

This Executor is best used for testing and debugging workflows locally. It does not support distributed execution, and is not recommended for production use. It also does nothing to manage resources on the machine, and ignores any set stage resources.

To use this Executor, set the services > compute > executor config target, for example:

services:
  compute:
    executor:
      target: flowdapt.compute.executor.local.LocalExecutor

Parameters:

Name	Type	Description	Default
use_processes	bool	Whether to use a ProcessPoolExecutor or a ThreadPoolExecutor	True
cpus	int | str	The number of processes/threads to use. If set to "auto", will use the number of CPUs on the machine.	'auto'
cluster_memory_socket_path	str	The path to the socket file for the ClusterMemoryServer, defaults to /tmp/flowdapt-cluster-memory.sock	SOCKET_PATH