workers

Subpackages

• llm
  • LLMWorker
    • LLMWorker.__init__()
    • LLMWorker.llm
    • LLMWorker.tool_call_active
    • LLMWorker.on_activated()
    • LLMWorker.queue_frame()
    • LLMWorker.build_tools()
    • LLMWorker.end()
    • LLMWorker.activate_worker()
    • LLMWorker.process_deferred_tool_frames()
  • LLMWorkerActivationArgs
    • LLMWorkerActivationArgs.messages
    • LLMWorkerActivationArgs.run_llm
    • LLMWorkerActivationArgs.messages
    • LLMWorkerActivationArgs.run_llm
  • LLMContextWorker
    • LLMContextWorker.__init__()
    • LLMContextWorker.context
    • LLMContextWorker.user_aggregator
    • LLMContextWorker.assistant_aggregator
  • tool()
  • Submodules
    • llm_context_worker
      • LLMContextWorker
    • llm_worker
      • PipelineFlushFrame
      • LLMWorkerActivationArgs
      • LLMWorker
    • tool_decorator
      • tool()
• proxy
  • WebSocketProxyClient
    • WebSocketProxyClient.__init__()
    • WebSocketProxyClient.on_activated()
    • WebSocketProxyClient.stop()
    • WebSocketProxyClient.on_bus_message()
  • WebSocketProxyServer
    • WebSocketProxyServer.__init__()
    • WebSocketProxyServer.start()
    • WebSocketProxyServer.stop()
    • WebSocketProxyServer.on_worker_ready()
    • WebSocketProxyServer.on_bus_message()
  • Subpackages
    • websocket
      • WebSocketProxyClient
      • WebSocketProxyServer
      • Submodules
• ui
  • BusUICommandMessage
    • BusUICommandMessage.command_name
    • BusUICommandMessage.payload
  • BusUIEventMessage
    • BusUIEventMessage.event_name
    • BusUIEventMessage.payload
  • BusUIJobCompletedMessage
    • BusUIJobCompletedMessage.job_id
    • BusUIJobCompletedMessage.worker_name
    • BusUIJobCompletedMessage.status
    • BusUIJobCompletedMessage.response
    • BusUIJobCompletedMessage.at
  • BusUIJobGroupCompletedMessage
    • BusUIJobGroupCompletedMessage.job_id
    • BusUIJobGroupCompletedMessage.at
  • BusUIJobGroupStartedMessage
    • BusUIJobGroupStartedMessage.job_id
    • BusUIJobGroupStartedMessage.workers
    • BusUIJobGroupStartedMessage.label
    • BusUIJobGroupStartedMessage.cancellable
    • BusUIJobGroupStartedMessage.at
  • BusUIJobUpdateMessage
    • BusUIJobUpdateMessage.job_id
    • BusUIJobUpdateMessage.worker_name
    • BusUIJobUpdateMessage.data
    • BusUIJobUpdateMessage.at
  • ReplyToolMixin
    • ReplyToolMixin.reply()
  • UIWorker
    • UIWorker.__init__()
    • UIWorker.send_command()
    • UIWorker.scroll_to()
    • UIWorker.highlight()
    • UIWorker.select_text()
    • UIWorker.click()
    • UIWorker.set_input_value()
    • UIWorker.on_bus_message()
    • UIWorker.current_job
    • UIWorker.render_query()
    • UIWorker.respond_to_job()
    • UIWorker.ui_job_group()
    • UIWorker.start_ui_job_group()
    • UIWorker.render_ui_state()
    • UIWorker.inject_ui_state()
    • UIWorker.render_ui_event()
  • ui_event()
  • Submodules
    • ui_event_decorator
      • ui_event()
    • ui_job_context
      • UIJobGroupContext
    • ui_prompts
    • ui_tools
      • ReplyToolMixin
    • ui_worker
      • UIWorker

Submodules

• base_worker
  • WorkerParams
    • WorkerParams.loop
  • WorkerActivationArgs
    • WorkerActivationArgs.metadata
    • WorkerActivationArgs.from_dict()
    • WorkerActivationArgs.to_dict()
  • BaseWorker
    • BaseWorker.__init__()
    • BaseWorker.bus
    • BaseWorker.active
    • BaseWorker.activation_args
    • BaseWorker.parent
    • BaseWorker.registry
    • BaseWorker.started_at
    • BaseWorker.bridged
    • BaseWorker.children
    • BaseWorker.active_jobs
    • BaseWorker.job_groups
    • BaseWorker.attach()
    • BaseWorker.cleanup()
    • BaseWorker.run()
    • BaseWorker.start()
    • BaseWorker.stop()
    • BaseWorker.end()
    • BaseWorker.cancel()
    • BaseWorker.wait()
    • BaseWorker.on_activated()
    • BaseWorker.on_deactivated()
    • BaseWorker.on_worker_ready()
    • BaseWorker.on_worker_failed()
    • BaseWorker.on_bus_message()
    • BaseWorker.on_job_request()
    • BaseWorker.on_job_response()
    • BaseWorker.on_job_update()
    • BaseWorker.on_job_update_requested()
    • BaseWorker.on_job_completed()
    • BaseWorker.on_job_error()
    • BaseWorker.on_job_stream_start()
    • BaseWorker.on_job_stream_data()
    • BaseWorker.on_job_stream_end()
    • BaseWorker.on_job_cancelled()
    • BaseWorker.send_bus_message()
    • BaseWorker.send_bus_error_message()
    • BaseWorker.add_workers()
    • BaseWorker.activate_worker()
    • BaseWorker.deactivate_worker()
    • BaseWorker.watch_workers()
    • BaseWorker.request_job()
    • BaseWorker.job()
    • BaseWorker.request_job_group()
    • BaseWorker.job_group()
    • BaseWorker.cancel_job_group()
    • BaseWorker.request_job_update()
    • BaseWorker.create_job_group_and_request_job()
    • BaseWorker.send_job_response()
    • BaseWorker.send_job_update()
    • BaseWorker.send_job_stream_start()
    • BaseWorker.send_job_stream_data()
    • BaseWorker.send_job_stream_end()
• runner
  • WorkerRunner
    • WorkerRunner.__init__()
    • WorkerRunner.bus
    • WorkerRunner.registry
    • WorkerRunner.add_workers()
    • WorkerRunner.run()
    • WorkerRunner.stop_when_done()
    • WorkerRunner.end()
    • WorkerRunner.cancel()
    • WorkerRunner.on_bus_message()