apache_beam.utils.thread_pool_executor module¶

class apache_beam.utils.thread_pool_executor.UnboundedThreadPoolExecutor(permitted_thread_age_in_seconds=30)[source]¶

Bases: concurrent.futures._base.Executor

submit(fn, *args, **kwargs)[source]¶

Attempts to submit the work item.

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