colmena

• colmena.task_server
  • colmena.task_server.parsl
    • ParslTaskServer
  • colmena.task_server.globus
    • GlobusComputeTaskServer
      • GlobusComputeTaskServer.perform_callback()
  • colmena.task_server.local
    • LocalTaskServer
  • colmena.task_server.base
    • BaseTaskServer
      • BaseTaskServer.listen_and_launch()
      • BaseTaskServer.process_queue()
      • BaseTaskServer.run()
    • FutureBasedTaskServer
      • FutureBasedTaskServer.perform_callback()
      • FutureBasedTaskServer.process_queue()
    • convert_to_colmena_method()
• colmena.queue
  • colmena.queue.python
    • PipeQueues
      • PipeQueues.flush()
  • colmena.queue.redis
    • RedisQueues
      • RedisQueues.connect()
      • RedisQueues.disconnect()
      • RedisQueues.flush()
      • RedisQueues.is_connected
  • colmena.queue.base
    • ColmenaQueues
      • ColmenaQueues.active_count
      • ColmenaQueues.flush()
      • ColmenaQueues.get_result()
      • ColmenaQueues.get_task()
      • ColmenaQueues.send_inputs()
      • ColmenaQueues.send_kill_signal()
      • ColmenaQueues.send_result()
      • ColmenaQueues.set_role()
      • ColmenaQueues.wait_until_done()
    • QueueRole
      • QueueRole.ANY
      • QueueRole.CLIENT
      • QueueRole.SERVER
• colmena.models
  • FailureInformation
    • FailureInformation.exception
    • FailureInformation.from_exception()
    • FailureInformation.model_config
    • FailureInformation.traceback
  • ResourceRequirements
    • ResourceRequirements.cpu_processes
    • ResourceRequirements.cpu_threads
    • ResourceRequirements.model_config
    • ResourceRequirements.node_count
    • ResourceRequirements.total_ranks
  • Result
    • Result.args
    • Result.complete
    • Result.deserialize()
    • Result.failure_info
    • Result.from_args_and_kwargs()
    • Result.inputs
    • Result.json()
    • Result.keep_inputs
    • Result.kwargs
    • Result.mark_compute_ended()
    • Result.mark_compute_started()
    • Result.mark_input_received()
    • Result.mark_result_received()
    • Result.mark_result_sent()
    • Result.mark_start_task_submission()
    • Result.mark_task_received()
    • Result.max_retries
    • Result.message_sizes
    • Result.method
    • Result.model_config
    • Result.proxystore_config
    • Result.proxystore_name
    • Result.proxystore_threshold
    • Result.resources
    • Result.retries
    • Result.serialization_method
    • Result.serialize()
    • Result.set_result()
    • Result.success
    • Result.task_id
    • Result.task_info
    • Result.time
    • Result.timestamp
    • Result.topic
    • Result.value
    • Result.worker_info
  • SerializationMethod
    • SerializationMethod.JSON
    • SerializationMethod.PICKLE
    • SerializationMethod.deserialize()
    • SerializationMethod.serialize()
• colmena.models.methods
  • ColmenaMethod
    • ColmenaMethod.name
    • ColmenaMethod.function()
  • PythonMethod
  • PythonGeneratorMethod
    • PythonGeneratorMethod.stream_result()
    • PythonGeneratorMethod.function()
  • ExecutableMethod
    • ExecutableMethod.executable
    • ExecutableMethod.mpi
    • ExecutableMethod.mpi_command_string
    • ExecutableMethod.render_mpi_launch()
    • ExecutableMethod.preprocess()
    • ExecutableMethod.execute()
    • ExecutableMethod.assemble_shell_cmd()
    • ExecutableMethod.postprocess()
    • ExecutableMethod.function()
• colmena.thinker
  • BaseThinker
    • BaseThinker.agent_name
    • BaseThinker.list_agents()
    • BaseThinker.logger
    • BaseThinker.make_logger()
    • BaseThinker.prepare_agent()
    • BaseThinker.run()
    • BaseThinker.tear_down_agent()
  • agent()
  • event_responder()
  • result_processor()
  • task_submitter()
  • colmena.thinker.resources
    • ReallocatorThread
      • ReallocatorThread.run()
    • ResourceCounter
      • ResourceCounter.acquire()
      • ResourceCounter.allocated_slots()
      • ResourceCounter.available_slots()
      • ResourceCounter.reallocate()
      • ResourceCounter.release()
      • ResourceCounter.unallocated_slots
• colmena.exceptions
  • KillSignalException
  • TimeoutException
• colmena.proxy
  • ProxyJSONSerializationWarning
  • get_store()
  • proxy_json_encoder()
  • resolve_proxies_async()
  • store_proxy_stats()