Index

A

add_to_whitelist() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method)

add_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method)

B

BadRegistration bar() (in module funcx.serialize.concretes) BaseStrategy (class in funcx.strategies) (class in funcx.strategies.base)

batch_run() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) broker (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

C

cancel() (funcx.providers.kubernetes.kube.KubernetesProvider method) (funcx.providers.KubernetesProvider method) (funcx.sdk.utils.futures.FuncXFuture method) check() (funcx.serialize.base.fxPicker_shared method) check_logged_in() (in module funcx.sdk.config) check_pidfile() (in module funcx.endpoint.endpoint) chomp() (funcx.serialize.base.fxPicker_shared method) cli_run() (in module funcx.endpoint.endpoint) (in module funcx.executors.high_throughput.funcx_manager) (in module funcx.executors.high_throughput.funcx_worker) (in module funcx.executors.high_throughput.interchange) CLIENT_ID (funcx.sdk.client.FuncXClient attribute) close() (funcx.executors.high_throughput.zmq_pipes.CommandClient method) (funcx.executors.high_throughput.zmq_pipes.ResultsIncoming method) (funcx.executors.high_throughput.zmq_pipes.TasksOutgoing method) (funcx.strategies.BaseStrategy method) (funcx.strategies.base.BaseStrategy method) (funcx.strategies.base.Timer method)

code_pickle (class in funcx.serialize.concretes) code_text_dill (class in funcx.serialize.concretes) code_text_inspect (class in funcx.serialize.concretes) CommandClient (class in funcx.executors.high_throughput.zmq_pipes) Config (class in funcx.config) configure_endpoint() (in module funcx.endpoint.endpoint) connect() (funcx.queues.base.FuncxQueue method) (funcx.queues.RedisQueue method) (funcx.queues.redis.redis_q.RedisQueue method) connected_workers (funcx.executors.high_throughput.executor.HighThroughputExecutor attribute) (funcx.executors.HighThroughputExecutor attribute) connection_info (funcx.executors.high_throughput.executor.HighThroughputExecutor attribute) (funcx.executors.HighThroughputExecutor attribute) (funcx.mock_broker.forwarder.Forwarder attribute) create_batch() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) create_reg_message() (funcx.executors.high_throughput.funcx_manager.Manager method) ctx (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

D

DEFAULT_MAX_REQUEST_SIZE (funcx.sdk.utils.throttling.ThrottledBaseClient attribute) DEFAULT_MAX_REQUESTS (funcx.sdk.utils.throttling.ThrottledBaseClient attribute) delete_from_whitelist() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) DeserializationError deserialize() (funcx.serialize.base.fxPicker_enforcer method) (funcx.serialize.concretes.code_pickle method) (funcx.serialize.concretes.code_text_dill method) (funcx.serialize.concretes.code_text_inspect method) (funcx.serialize.concretes.json_base64 method) (funcx.serialize.concretes.pickle_base64 method) (funcx.serialize.facade.FuncXSerializer method)

destroy() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) dispatch() (in module funcx.executors.high_throughput.interchange_task_dispatch) double() (in module funcx.mock_broker.forwarder) (in module funcx.mock_broker.test) dump() (in module funcx.endpoint.utils.zhelpers)

E

execute_task() (funcx.executors.high_throughput.funcx_worker.FuncXWorker method)

executor_starter() (in module funcx.executors.high_throughput.executor) expect_reply (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

F

fail() (in module funcx.mock_broker.test) failer() (in module funcx.mock_broker.forwarder) format_output() (in module funcx.sdk.config) Forwarder (class in funcx.mock_broker.forwarder) funcx (module) funcx.config (module) funcx.endpoint (module) funcx.endpoint.auth (module) funcx.endpoint.config (module) funcx.endpoint.endpoint (module) funcx.endpoint.list_endpoints (module) funcx.endpoint.utils (module) funcx.endpoint.utils.MDP (module) funcx.endpoint.utils.zhelpers (module) funcx.endpoint.utils.zmq_worker (module) funcx.endpoint.version (module) funcx.errors (module) funcx.executors (module) funcx.executors.high_throughput (module) funcx.executors.high_throughput.container_sched (module) funcx.executors.high_throughput.default_config (module) funcx.executors.high_throughput.executor (module) funcx.executors.high_throughput.funcx_manager (module) funcx.executors.high_throughput.funcx_worker (module) funcx.executors.high_throughput.global_config (module) funcx.executors.high_throughput.interchange (module) funcx.executors.high_throughput.interchange_task_dispatch (module) funcx.executors.high_throughput.worker_map (module) funcx.executors.high_throughput.zmq_pipes (module) funcx.mock_broker (module) funcx.mock_broker.forwarder (module) funcx.mock_broker.mock_broker (module) funcx.mock_broker.mock_tester (module) funcx.mock_broker.test (module)

funcx.providers (module) funcx.providers.kubernetes (module) funcx.providers.kubernetes.kube (module) funcx.providers.kubernetes.template (module) funcx.queues (module) funcx.queues.base (module) funcx.queues.redis (module) funcx.queues.redis.redis_q (module) funcx.sdk (module) funcx.sdk.client (module) funcx.sdk.config (module) funcx.sdk.utils (module) funcx.sdk.utils.futures (module) funcx.sdk.utils.throttling (module) funcx.sdk.version (module) funcx.serialize (module) funcx.serialize.base (module) funcx.serialize.concretes (module) funcx.serialize.facade (module) funcx.strategies (module) funcx.strategies.base (module) funcx.strategies.kube_simple (module) funcx.strategies.simple (module) funcx.version (module) FuncXClient (class in funcx) (class in funcx.sdk.client) FuncxError FuncXFuture (class in funcx.sdk.utils.futures) FuncxQueue (class in funcx.queues.base) FuncXSerializer (class in funcx.serialize.facade) FuncXUnreachable FuncXWorker (class in funcx.executors.high_throughput.funcx_worker) fxPicker_enforcer (class in funcx.serialize.base) fxPicker_shared (class in funcx.serialize.base)

G

get() (funcx.executors.high_throughput.zmq_pipes.ResultsIncoming method) (funcx.queues.RedisQueue method) (funcx.queues.base.FuncxQueue method) (funcx.queues.redis.redis_q.RedisQueue method) get_batch_result() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_batch_status() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_container() (funcx.executors.high_throughput.interchange.Interchange method) (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_containers() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_endpoint_status() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method)

get_next_worker_q() (funcx.executors.high_throughput.worker_map.WorkerMap method) get_outstanding_breakdown() (funcx.executors.high_throughput.interchange.Interchange method) get_result() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_status_report() (funcx.executors.high_throughput.interchange.Interchange method) get_task_status() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_tasks() (funcx.executors.high_throughput.interchange.Interchange method) get_tasks_hard() (in module funcx.executors.high_throughput.interchange_task_dispatch) get_tasks_soft() (in module funcx.executors.high_throughput.interchange_task_dispatch) get_total_live_workers() (funcx.executors.high_throughput.interchange.Interchange method) get_total_tasks_outstanding() (funcx.executors.high_throughput.interchange.Interchange method) get_whitelist() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method) get_worker_counts() (funcx.executors.high_throughput.worker_map.WorkerMap method)

H

handle_app_update() (funcx.mock_broker.forwarder.Forwarder method) heartbeat (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) heartbeat() (funcx.executors.high_throughput.funcx_manager.Manager method) heartbeat_at (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) HEARTBEAT_LIVENESS (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

HighThroughputExecutor (class in funcx.executors) (class in funcx.executors.high_throughput.executor) hold_manager() (funcx.executors.high_throughput.interchange.Interchange method) hold_worker() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method)

I

identifier (funcx.serialize.base.fxPicker_shared attribute) init_endpoint() (in module funcx.endpoint.endpoint) init_endpoint_dir() (in module funcx.endpoint.endpoint) initialize_scaling() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method)

Interchange (class in funcx.executors.high_throughput.interchange) internal_auth_client() (in module funcx.sdk.config) is_connected (funcx.queues.base.FuncxQueue attribute) (funcx.queues.RedisQueue attribute) (funcx.queues.redis.redis_q.RedisQueue attribute)

J

json_base64 (class in funcx.serialize.concretes)

K

KubernetesProvider (class in funcx.providers) (class in funcx.providers.kubernetes.kube)

KubeSimpleStrategy (class in funcx.strategies) (class in funcx.strategies.kube_simple)

L

label (funcx.providers.kubernetes.kube.KubernetesProvider attribute) (funcx.providers.KubernetesProvider attribute) list_endpoints() (in module funcx.endpoint.list_endpoints) list_mappings() (in module funcx.mock_broker.mock_broker) liveness (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

load_auth_client() (in module funcx.endpoint.auth) load_config() (funcx.executors.high_throughput.interchange.Interchange method) load_endpoint() (in module funcx.endpoint.endpoint) logout() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) lookup_option() (in module funcx.sdk.config)

M

make_callback() (funcx.strategies.base.BaseStrategy method) (funcx.strategies.BaseStrategy method) (funcx.strategies.base.Timer method) MalformedResponse Manager (class in funcx.executors.high_throughput.funcx_manager)

ManagerLost map_run() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) MaxRequestsExceeded MaxRequestSizeExceeded migrate_tasks_to_internal() (funcx.executors.high_throughput.interchange.Interchange method)

N

naive_interchange_task_dispatch() (in module funcx.executors.high_throughput.interchange_task_dispatch) naive_scheduler() (in module funcx.executors.high_throughput.container_sched)

NotConnected notify() (funcx.strategies.base.BaseStrategy method) (funcx.strategies.BaseStrategy method)

O

outstanding (funcx.executors.high_throughput.executor.HighThroughputExecutor attribute) (funcx.executors.HighThroughputExecutor attribute)

P

pack_buffers() (funcx.serialize.facade.FuncXSerializer method) pickle_base64 (class in funcx.serialize.concretes) provider_status() (funcx.executors.high_throughput.interchange.Interchange method) pull_tasks() (funcx.executors.high_throughput.funcx_manager.Manager method) push_results() (funcx.executors.high_throughput.funcx_manager.Manager method)

put() (funcx.executors.high_throughput.zmq_pipes.TasksOutgoing method) (funcx.queues.RedisQueue method) (funcx.queues.base.FuncxQueue method) (funcx.queues.redis.redis_q.RedisQueue method) put_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method)

R

ready_worker_count() (funcx.executors.high_throughput.worker_map.WorkerMap method) reconnect (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) reconnect_to_broker() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) recv() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) RedisQueue (class in funcx.queues) (class in funcx.queues.redis.redis_q) register() (in module funcx.mock_broker.mock_broker) register_container() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) register_endpoint() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) (in module funcx.endpoint.endpoint) register_function() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) register_with_hub() (in module funcx.endpoint.endpoint) register_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method)

registration_message() (funcx.executors.high_throughput.funcx_worker.FuncXWorker method) RegistrationError RemoteExceptionWrapper (class in funcx.serialize.base) remove_option() (in module funcx.sdk.config) remove_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method) remove_worker_init() (funcx.executors.high_throughput.funcx_manager.Manager method) reply_to (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) request_close() (funcx.executors.high_throughput.zmq_pipes.ResultsIncoming method) request_status_info() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) reraise() (funcx.serialize.base.RemoteExceptionWrapper method) ResultsIncoming (class in funcx.executors.high_throughput.zmq_pipes) run() (funcx.executors.high_throughput.zmq_pipes.CommandClient method) (funcx.FuncXClient method) (funcx.mock_broker.forwarder.Forwarder method) (funcx.sdk.client.FuncXClient method) running() (funcx.sdk.utils.futures.FuncXFuture method)

S

safeprint() (in module funcx.sdk.config) scale_in() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.executors.high_throughput.interchange.Interchange method) scale_out() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.executors.high_throughput.interchange.Interchange method) scaling_enabled (funcx.executors.high_throughput.executor.HighThroughputExecutor attribute) (funcx.executors.HighThroughputExecutor attribute) send() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) send_to_broker() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) serialize() (funcx.serialize.base.fxPicker_enforcer method) (funcx.serialize.concretes.code_pickle method) (funcx.serialize.concretes.code_text_dill method) (funcx.serialize.concretes.code_text_inspect method) (funcx.serialize.concretes.json_base64 method) (funcx.serialize.concretes.pickle_base64 method) (funcx.serialize.facade.FuncXSerializer method) SerializerError (class in funcx.serialize.base) service (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) set_file_logger() (in module funcx) set_id() (in module funcx.endpoint.utils.zhelpers) set_stream_logger() (in module funcx) shutdown() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) ShutdownRequest SimpleStrategy (class in funcx.strategies) (class in funcx.strategies.simple) socket_set_hwm() (in module funcx.endpoint.utils.zhelpers)

spawn_forwarder() (in module funcx.mock_broker.forwarder) spin_down_workers() (funcx.executors.high_throughput.worker_map.WorkerMap method) spin_up_workers() (funcx.executors.high_throughput.worker_map.WorkerMap method) start() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.executors.high_throughput.funcx_manager.Manager method) (funcx.executors.high_throughput.funcx_worker.FuncXWorker method) (funcx.executors.high_throughput.interchange.Interchange method) (funcx.strategies.BaseStrategy method) (funcx.strategies.base.BaseStrategy method) start_endpoint() (in module funcx.endpoint.endpoint) start_file_logger() (in module funcx.executors.high_throughput.interchange) starter() (in module funcx.executors.high_throughput.interchange) status() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.providers.KubernetesProvider method) (funcx.providers.kubernetes.kube.KubernetesProvider method) stop() (funcx.executors.high_throughput.interchange.Interchange method) stop_endpoint() (in module funcx.endpoint.endpoint) strategize() (funcx.strategies.base.BaseStrategy method) (funcx.strategies.BaseStrategy method) (funcx.strategies.KubeSimpleStrategy method) (funcx.strategies.SimpleStrategy method) (funcx.strategies.kube_simple.KubeSimpleStrategy method) (funcx.strategies.simple.SimpleStrategy method) submit() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.providers.KubernetesProvider method) (funcx.providers.kubernetes.kube.KubernetesProvider method)

T

TasksOutgoing (class in funcx.executors.high_throughput.zmq_pipes) test() (in module funcx.mock_broker.mock_tester) (in module funcx.queues.redis.redis_q) test_1() (in module funcx.mock_broker.test) test_2() (in module funcx.mock_broker.test) test_3() (in module funcx.mock_broker.test) throttle_max_requests() (funcx.sdk.utils.throttling.ThrottledBaseClient method)

throttle_request_size() (funcx.sdk.utils.throttling.ThrottledBaseClient method) ThrottledBaseClient (class in funcx.sdk.utils.throttling) ThrottlingException timeout (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) Timer (class in funcx.strategies.base) TOKEN_DIR (funcx.sdk.client.FuncXClient attribute) TOKEN_FILENAME (funcx.sdk.client.FuncXClient attribute)

U

unpack_and_deserialize() (funcx.serialize.facade.FuncXSerializer method) unpack_buffers() (funcx.serialize.facade.FuncXSerializer method)

update_table() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) update_worker_idle() (funcx.executors.high_throughput.worker_map.WorkerMap method)

V

verbose (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

W

wait_for_endpoint() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) weakref_cb() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method)

worker (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) WorkerMap (class in funcx.executors.high_throughput.worker_map) write_option() (in module funcx.sdk.config)

Z

ZMQWorker (class in funcx.endpoint.utils.zmq_worker)

zpipe() (in module funcx.endpoint.utils.zhelpers)