fleet-framework 1.1.0

generic distributed-automation framework — master/worker, browser pool, anti-bot helpers, and abstract automation contracts (SERP, content, news, place, marketplace, jobs, social)

Fleet

A framework for running Python automations across a fleet of machines. You write the automation once; Fleet hands it out to your workers, keeps them running, restarts the ones that fall over, and ships their output where you want it to go.

One process, the master, runs on one host. Many workers, one per machine, do the actual work. Output from one workload can feed another across hosts; you don't write the plumbing.

Battle-tested in the wild as the brains behind a Cloudflare Turnstile-solving farm.

What it is

Fleet is two pieces: a master and some workers.

The master runs on one machine. It's where you set what to do and read what got done. Workers run on every other machine in your fleet. They check in with the master, get instructions, and do the work.

The work itself is a small Python class you write. Ship it as a pip package, install it on the machines, and Fleet finds it on its own.

What's in the box

• One master, many workers. Change config in one place, every worker follows.
• Workers heal themselves. A crashed task is restarted on the next tick.
• Workloads hand output to each other across machines, no glue code.
• Optional Chromium pool for anything that needs a real browser.
• Auth, a small dashboard, and observability hooks. All wired up.

Getting started

pip install fleet-framework

Then write your automation as a Python class. Roughly 30 lines:

import asyncio
import httpx
from fleet.core import BaseConfig, ContinuousAutomation, register

class PingerConfig(BaseConfig):
    url: str
    interval_seconds: float = 5.0

@register("pinger")
class Pinger(ContinuousAutomation[PingerConfig]):
    Config = PingerConfig

    async def run_slot(self, ctx):
        async with httpx.AsyncClient(proxy=ctx.proxy) as client:
            while not ctx.shutdown.is_set():
                r = await client.get(ctx.config.url)
                await ctx.emit({"status": r.status_code})
                await asyncio.sleep(ctx.config.interval_seconds)

Full walkthrough — master, worker, config, output — at http://fleet.hackmap.win/getting-started/quickstart.

Documentation

Full docs live at http://fleet.hackmap.win/.

• Introduction
• Installation · Quickstart · Your first automation
• Architecture · Automations · Primitives
• Continuous automations · Batch automations · Inter-automation comms
• Browser-based automations · Deployment
• REST API · WebSocket protocol · CLI
• Auth · Observability · Troubleshooting

License

MIT. See LICENSE.