Info: v0.7 is talking to a new supabase backend. v0.6 will remain online until at least December 1st, 2025.
This repo is research code. Please use github issues or contact me via email (niels dot warncke at gmail dot com) or slack when you encounter issues.
An openai-like sdk with the flexibility of working on a local GPU: finetune, inference, API deployments and custom workloads on managed runpod instances.
Run pip install openweights or install from source via pip install -e .
-
Create an API key You can create one via the
ow signupor using the dashboard. -
Start the cluster manager (skip this if you got an API key for a managed cluster) The cluster manager is the service that monitors the job queue and starts runpod workers. You have different options to start the cluster
ow cluster --env-file path/to/env # Run locally
ow deploy --env-file path/to/env # Run on a runpod cpu instance
# Or managed, if you trust us with your API keys (usually a bad idea, but okay if you know us personally)
ow env import path/to/env
ow manage startIn all cases, the env file needs at least all envs defined in .env.worker.example.
- Submit a job
from openweights import OpenWeights
ow = OpenWeights()
training_file = ow.files.upload("data/train.jsonl", purpose="conversations")["id"]
job = ow.fine_tuning.create(
model="unsloth/Qwen3-4B",
training_file=training_file,
loss="sft",
epochs=1,
learning_rate=1e-4,
r=32,
)For more examples, checkout the cookbook.
openweights lets you submit jobs that will be run on managed runpod instances. It supports a range of built-in jobs out-of-the-box, but is built for custom workloads.
A custom job lets you run a script that you would normally run on one GPU as a job.
Example:
from openweights import OpenWeights, register, Jobs
ow = OpenWeights()
@register('my_custom_job')
class MyCustomJob(Jobs):
mount = {
'local/path/to/script.py': 'script.py',
'local/path/to/dir/': 'dirname/'
}
params: Type[BaseModel] = MyParams # Your Pydantic model for params
requires_vram_gb: int = 24
base_image: str = 'nielsrolf/ow-default' # optional
def get_entrypoint(self, validated_params: BaseModel) -> str:
# Get the entrypoint command for the job.
return f'python script.py {json.dumps(validated_params.model_dump())}'from openweights import OpenWeights
ow = OpenWeights()
file = ow.files.create(
file=open("mydata.jsonl", "rb"),
purpose="conversations"
)
job = ow.inference.create(
model=model,
input_file_id=file['id'],
max_tokens=1000,
temperature=1,
min_tokens=600,
)
# Wait or poll until job is done, then:
if job.status == 'completed':
output_file_id = job['outputs']['file']
output = ow.files.content(output_file_id).decode('utf-8')
print(output)from openweights import OpenWeights
ow = OpenWeights()
model = 'unsloth/llama-3-8b-Instruct'
# async with ow.api.deploy(model) also works
with ow.api.deploy(model): # async with ow.api.deploy(model) also works
# entering the context manager is equivalent to temp_api = ow.api.deploy(model) ; api.up()
completion = ow.chat.completions.create(
model=model,
messages=[{"role": "user", "content": "is 9.11 > 9.9?"}]
)
print(completion.choices[0].message) # when this context manager exits, it calls api.down()from openweights import OpenWeights
ow = OpenWeights()
job = ow.inspect_ai.create(
model='meta-llama/Llama-3.3-70B-Instruct',
eval_name='inspect_evals/gpqa_diamond',
options='--top-p 0.9', # Can be any options that `inspect eval` accepts - we simply pass them on without validation
)
if job.status == 'completed':
job.download('output')Use ow {cmd} --help for more help on the available commands:
❯ ow --help
usage: ow [-h] {ssh,exec,signup,cluster,worker,token,ls,cancel,logs,fetch,serve,deploy,env,manage} ...
OpenWeights CLI for remote GPU operations
positional arguments:
{ssh,exec,signup,cluster,worker,token,ls,cancel,logs,fetch,serve,deploy,env,manage}
ssh Start or attach to a remote shell with live file sync.
exec Execute a command on a remote GPU with file sync.
signup Create a new user, organization, and API key.
cluster Run the cluster manager locally with your own infrastructure.
worker Run a worker to execute jobs from the queue.
token Manage API tokens for organizations.
ls List job IDs.
cancel Cancel jobs by ID.
logs Display logs for a job.
fetch Fetch file content by ID.
serve Start the dashboard backend server.
deploy Deploy a cluster instance on RunPod.
env Manage organization secrets (environment variables).
manage Control managed cluster infrastructure.
options:
-h, --help show this help message and exitFor developing custom jobs, ow ssh is great - it starts a pod, connects via ssh, and live-syncs the local CWD into the remote. This allows editing finetuning code locally and testing it immediately.
The job_id is based on the params hash, which means that if you submit the same job many times, it will only run once. If you resubmit a failed or canceled job, it will reset the job status to pending.
Originally created by Niels Warncke (@nielsrolf).
If you find this repo useful for your research and want to cite it, you can do so via:
@misc{warncke_openweights_2025,
author = {Niels Warncke},
title = {OpenWeights},
howpublished = {\url{https://github.com/longtermrisk/openweights}},
note = {Commit abcdefg • accessed DD Mon YYYY},
year = {2025}
}