c7n.executor module

class c7n.executor.ExecutorRegistry(plugin_type)

Bases: c7n.registry.PluginRegistry

class c7n.executor.MainThreadExecutor(*args, **kw)

Bases: object

For running tests.

c7n_async == True -> catch exceptions and store them in the future. c7n_async == False -> let exceptions bubble up.

c7n_async = True

map(func, iterable)

submit(func, *args, **kw)

type = 'main'

type_aliases = None

class c7n.executor.MainThreadFuture(value, exception=None)

Bases: object

add_done_callback(fn)

cancel()

cancelled()

done()

exception()

result(timeout=None)

c7n.executor.executor(name, **kw)