inginious.backend package¶

Submodules¶

class inginious.backend.backend.AgentInfo(name, environments)¶

Bases: tuple

class inginious.backend.backend.Backend(context, agent_addr, client_addr)[source]¶

Bases: object

Backend. Central point of the architecture, manages communication between clients (frontends) and agents. Schedule jobs on agents.

async handle_agent_hello(agent_addr, message: inginious.common.messages.AgentHello)[source]¶: Handle an AgentAvailable message. Add agent_addr to the list of available agents

async handle_agent_job_done(agent_addr, message: inginious.common.messages.AgentJobDone)[source]¶: Handle an AgentJobDone message. Send the data back to the client, and start new job if needed

async handle_agent_job_ssh_debug(agent_addr, message: inginious.common.messages.AgentJobSSHDebug)[source]¶: Handle an AgentJobSSHDebug message. Send the data back to the client

async handle_agent_job_started(agent_addr, message: inginious.common.messages.AgentJobStarted)[source]¶: Handle an AgentJobStarted message. Send the data back to the client

async handle_agent_message(agent_addr, message)[source]¶: Dispatch messages received from agents to the right handlers

async handle_client_get_queue(client_addr, _: inginious.common.messages.ClientGetQueue)[source]¶: Handles a ClientGetQueue message. Send back info about the job queue

async handle_client_hello(client_addr, _: inginious.common.messages.ClientHello)[source]¶: Handle an ClientHello message. Send available environments to the client

async handle_client_kill_job(client_addr, message: inginious.common.messages.ClientKillJob)[source]¶: Handle an ClientKillJob message. Remove a job from the waiting list or send the kill message to the right agent.

async handle_client_message(client_addr, message)[source]¶: Dispatch messages received from clients to the right handlers

async handle_client_new_job(client_addr, message: inginious.common.messages.ClientNewJob)[source]¶: Handle an ClientNewJob message. Add a job to the queue and triggers an update

async handle_client_ping(client_addr, _: inginious.common.messages.Ping)[source]¶: Handle an Ping message. Pong the client

async send_environment_update_to_client(client_addrs)[source]¶

Parameters: client_addrs – list of clients to which we should send the update

class inginious.backend.backend.EnvironmentInfo(last_id, created_last, agents, type)¶

Bases: tuple

class inginious.backend.backend.RunningJob(agent_addr, client_addr, msg, time_started)¶

Bases: tuple

class inginious.backend.backend.WaitingJob(priority, time_received, client_addr, job_id, msg)¶

Bases: tuple