Storage & Artifacts

# .env
STORAGE_BACKEND=minio
MINIO_ENDPOINT=localhost:9000
MINIO_ACCESS_KEY=minioadmin
MINIO_SECRET_KEY=minioadmin
MINIO_SECURE=false  # Set to true for HTTPS

# .env
STORAGE_BACKEND=s3
AWS_ACCESS_KEY_ID=your_access_key
AWS_SECRET_ACCESS_KEY=your_secret_key
AWS_REGION=us-east-1
S3_BUCKET=laddr-artifacts

# .env
STORAGE_BACKEND=local
STORAGE_PATH=./storage

from laddr import Agent

# Artifacts are automatically stored when using system tools
result = await agent.delegate_task(
    agent_name="processor",
    task_description="Process large dataset",
    task="process",
    task_data={"data": large_dataset}  # Automatically stored if large
)

from laddr import override_system_tool, ArtifactStorageTool

@override_system_tool("system_store_artifact")
async def custom_storage(
    data: dict,
    artifact_type: str,
    metadata: dict = None,
    bucket: str = None,
    _artifact_storage=None,
    **kwargs
):
    """Custom artifact storage with compression."""
    storage_tool = ArtifactStorageTool(
        storage_backend=_artifact_storage,
        default_bucket=bucket or "artifacts"
    )
    
    # Add custom logic (compression, encryption, etc.)
    return await storage_tool.store_artifact(
        data=data,
        artifact_type=artifact_type,
        metadata=metadata,
        bucket=bucket
    )

# .env
STORAGE_DEFAULT_BUCKET=artifacts
STORAGE_ARTIFACTS_BUCKET=laddr-artifacts
STORAGE_LOGS_BUCKET=laddr-logs

# .env
STORAGE_MAX_SIZE=1073741824  # 1GB in bytes
STORAGE_RETENTION_DAYS=30

# Store different types in different buckets
await store_artifact(data, artifact_type="result", bucket="results")
await store_artifact(data, artifact_type="log", bucket="logs")
await store_artifact(data, artifact_type="cache", bucket="cache")

# .env
STORAGE_RETENTION_DAYS=30  # Delete artifacts older than 30 days
STORAGE_CLEANUP_INTERVAL=3600  # Run cleanup every hour