apache_beam.utils.thread_pool_executor module

class apache_beam.utils.thread_pool_executor.UnboundedThreadPoolExecutor

Bases: concurrent.futures._base.Executor

submit(fn, *args, **kwargs)

Attempts to submit the work item.

A runtime error is raised if the pool has been shutdown.

shutdown(wait=True)

apache_beam.utils.thread_pool_executor.shared_unbounded_instance()