No Cortex.
The Dendrites decide.

# SDK + CLI + httpx (used by the HuggingFace Neuron wrapper)
pip install -e cosmonapse-core/packages/python-sdk
pip install -e cosmonapse-core/packages/cli
pip install httpx

# Hugging Face token — read scope is enough
$ export HF_TOKEN=hf_xxxxxxxxxxxxxxxxxxxxxxxx

$ cosmo synapse start memory --namespace=quickstart

  URL:        cosmo://127.0.0.1:7070
  Namespace:  quickstart
  Transport:  TCP + NDJSON  (single-host dev only)
  ────────────────────────────────────────────────

import asyncio, hashlib, os
from cosmonapse import Axon, Neuron, Dendrite, SignalType, connect_synapse

SYNAPSE_URL = "cosmo://127.0.0.1:7070"   # ← the only line that changes per transport
NAMESPACE   = "quickstart"
MY_ID       = "worker-a"                 # worker-b differs only here
PEERS       = ("worker-a", "worker-b")   # every peer knows the pool

def owner_of(trace_id: str) -> str:
    """Pure function: every peer computes the SAME owner — no coordination."""
    h = int(hashlib.sha1(trace_id.encode()).hexdigest(), 16)
    return PEERS[h % len(PEERS)]

async def main():
    # The Axon is NOT attached — we route by hash, not by neuron-id.
    axon = Axon(
        neuron_id=MY_ID,
        neuron_fn=Neuron(
            source="huggingface",
            endpoint="https://router.huggingface.co",
            model="meta-llama/Llama-3.1-8B-Instruct",
            api_key=os.environ["HF_TOKEN"],
            use_chat_api=True, max_new_tokens=128,
        ),
        capabilities=["chat"],
    )

    synapse  = await connect_synapse(SYNAPSE_URL)
    dendrite = Dendrite(synapse=synapse, namespace=NAMESPACE,
                        dendrite_id=MY_ID, heartbeat_s=0)

    async def on_task(task):
        if owner_of(task.trace_id) != MY_ID:
            return                              # a peer owns this one
        print(f"[{MY_ID}] claims {task.trace_id[4:12]}")
        reply = await axon.handle_task(task)   # run the Neuron
        await dendrite.publish(reply)          # emit AGENT_OUTPUT

    try:
        async with dendrite:
            await dendrite.subscribe(SignalType.TASK, on_task)
            print(f"{MY_ID} listening — no cortex, no queue")
            await asyncio.Event().wait()
    finally:
        await synapse.close()

asyncio.run(main())

import asyncio
from cosmonapse import Dendrite, connect_synapse, new_trace_id

SYNAPSE_URL = "cosmo://127.0.0.1:7070"

async def main():
    synapse  = await connect_synapse(SYNAPSE_URL)
    dendrite = Dendrite(synapse=synapse, namespace="quickstart",
                        dendrite_id="producer", heartbeat_s=0)
    pending = {}

    @dendrite.on_agent_output
    async def _on_output(sig):
        fut = pending.pop(sig.trace_id, None)
        if fut and not fut.done():
            fut.set_result((sig.neuron, sig.payload.get("output", {})))

    prompts = ["the sun", "the moon", "the sea", "the wind"]
    try:
        async with dendrite:
            for p in prompts:
                trace_id = new_trace_id()
                fut = asyncio.get_running_loop().create_future()
                pending[trace_id] = fut
                # The producer does NO routing — it just drops work in.
                await dendrite.dispatch_task(neuron="pool",
                                             input={"prompt": p}, trace_id=trace_id)
                who, out = await asyncio.wait_for(fut, timeout=60)
                print(f"{who} answered: {out.get('response', '').strip()}")
    finally:
        await synapse.close()

asyncio.run(main())

# terminal 1 — the bus
$ cosmo synapse start memory --namespace=quickstart

# terminal 2 — first worker
$ python worker_a.py

# terminal 3 — second worker
$ python worker_b.py

# terminal 4 — the producer
$ python producer.py

$ python producer.py
# …meanwhile, in the two worker terminals:
[worker-b] claims a3f2c1d8
[worker-a] claims 7b1e0942
[worker-a] claims 11ce88a4
[worker-b] claims 92aa5b30

# producer.py prints, in order:
worker-b answered: Golden disc ascends — silence breaks into light.
worker-a answered: Pale lantern in the dark — tides remember her face.
worker-a answered: Salt sighs against stone, an old song the wind forgot.
worker-b answered: Invisible river — it bends the wheat into prayer.