dara.server.worker module# add_job_to_queue(job, user)[source]# Add a job to the queue for remote execution. get_all_pending_jobs(sort_by_submitted_time=False)[source]# Add all pending jobs to the queue for remote execution. mark_running_jobs_as_fizzled()[source]# Mark all running jobs as fizzled. run_job(uuid)[source]# Run a job remotely by its UUID. worker_process()[source]# Start the Ray worker process.
