Quick Start

Get TaskDaemon running in under 5 minutes

Quick Start

Get TaskDaemon running in under 5 minutes.

Prerequisites

Docker installed and running

Steps

1. Create a Handler

   Create a new directory and add a simple Python handler:

   mkdir taskdaemon-quickstart && cd taskdaemon-quickstart
   

   Create handler.py:

   handler.py

   import json
   import sys
   
   for line in sys.stdin:
       task = json.loads(line)
       name = task["task_data"].get("name", "World")
       result = {"message": f"Hello, {name}!"}
       print(json.dumps({"status": "success", "result": result}), flush=True)
   

   Create Dockerfile.handler:

   Dockerfile.handler

   FROM python:3.11-slim
   COPY handler.py /app/
   WORKDIR /app
   CMD ["python", "-u", "handler.py"]
   
2. Build the Handler Image

   docker build -f Dockerfile.handler -t my-greeter:latest .
   
3. Create Handler Config

   Create handlers.toml:

   handlers.toml

   [handlers.greet]
   image = "my-greeter:latest"
   instances = 2
   handler_selection = "round-robin"
   
4. Start TaskDaemon

   docker run -d --name taskdaemon \
     -p 8080:8080 \
     -v $(pwd)/handlers.toml:/app/handlers.toml \
     -v /var/run/docker.sock:/var/run/docker.sock \
     -e DAEMON_QUEUE_TYPE=hybrid \
     mshelia/taskdaemon
   

   Wait a few seconds, then check logs:

   docker logs taskdaemon
   

   You should see:

   INFO task_daemon: TaskDaemon started http_port=8080 grpc_port=50051 workers=2
   
5. Queue a Task

   curl -X POST http://localhost:8080/queue \
     -H "Content-Type: application/json" \
     -d '{"type": "greet", "data": {"name": "TaskDaemon"}}'
   

   Response:

   {"task_id":"550e8400-e29b-41d4-a716-446655440000"}
   
6. Check Result

   curl http://localhost:8080/api/tasks/<task_id>
   

   Response:

   {
     "id": "550e8400-e29b-41d4-a716-446655440000",
     "status": "completed",
     "result": {"message": "Hello, TaskDaemon!"}
   }
   

Cleanup

docker stop taskdaemon && docker rm taskdaemon

Complete Script

Here’s everything in one script:

quickstart.sh

quickstart.sh

#!/bin/bash
set -e

# Create handler
cat > handler.py << 'EOF'
import json
import sys

for line in sys.stdin:
    task = json.loads(line)
    name = task["task_data"].get("name", "World")
    result = {"message": f"Hello, {name}!"}
    print(json.dumps({"status": "success", "result": result}), flush=True)
EOF

# Create Dockerfile
cat > Dockerfile.handler << 'EOF'
FROM python:3.11-slim
COPY handler.py /app/
WORKDIR /app
CMD ["python", "-u", "handler.py"]
EOF

# Create config
cat > handlers.toml << 'EOF'
[handlers.greet]
image = "my-greeter:latest"
instances = 2
handler_selection = "round-robin"
EOF

# Build handler
docker build -f Dockerfile.handler -t my-greeter:latest .

# Start TaskDaemon
docker run -d --name taskdaemon \
  -p 8080:8080 \
  -v $(pwd)/handlers.toml:/app/handlers.toml \
  -v /var/run/docker.sock:/var/run/docker.sock \
  -e DAEMON_QUEUE_TYPE=hybrid \
  mshelia/taskdaemon

echo "Waiting for startup..."
sleep 3

# Queue task
TASK_ID=$(curl -s -X POST http://localhost:8080/queue \
  -H "Content-Type: application/json" \
  -d '{"type": "greet", "data": {"name": "TaskDaemon"}}' | jq -r '.task_id')

echo "Task ID: $TASK_ID"
sleep 2

# Get result
curl -s http://localhost:8080/api/tasks/$TASK_ID | jq

# Cleanup
docker stop taskdaemon && docker rm taskdaemon

Next Steps

Use an SDK

Cleaner handler code with official SDKs

Sample Project

Complete working example with C++ handler

Configure Strategies

FIFO, LIFO, or Priority task ordering

Add Monitoring

Prometheus metrics and Grafana dashboards