Temporal

Integrate You.com’s APIs into Temporal workflows as durable activities that survive crashes and automatically resume where they left off.

The youdotcom-temporal package provides six activities covering every You.com API, wrapped in a YouPlugin (a Temporal SimplePlugin) for one-line worker setup:

1. youdotcom_search for real-time web and news search
2. youdotcom_answer for synthesized answers with inline citations
3. youdotcom_research for multi-step research with citations
4. youdotcom_research_background for long-running background research
5. youdotcom_finance_research for finance-focused research
6. youdotcom_contents for webpage content extraction

Every activity returns JSON-serializable dicts, maps SDK errors to Temporal error types with correct retryability, and disables the SDK’s built-in HTTP retries so Temporal is the single retry authority.

Getting Started

$
pip install youdotcom-temporal

$
export YDC_API_KEY="<YDC_API_KEY>"

$
temporal server start-dev

Configure Credentials

The plugin reads the API key from the YDC_API_KEY environment variable on the worker. Never pass the key as a workflow or activity argument—Temporal records workflow inputs in event history in plaintext.

To override the resolved key programmatically on the worker:

1
from youdotcom_temporal import YouConfig, set_config
2
3
set_config(YouConfig(api_key="your-api-key"))

YouConfig also accepts server_url and timeout_seconds (defaults to 300 seconds).

Usage

1
from temporalio.client import Client
2
from temporalio.worker import Worker
3
from youdotcom_temporal import YouPlugin
4
5
from hello_search_workflow import HelloSearch  # see examples/
6
7
async def main():
8
    client = await Client.connect("localhost:7233")
9
    worker = Worker(
10
        client,
11
        task_queue="you-search",
12
        workflows=[HelloSearch],
13
        plugins=[YouPlugin()],
14
    )
15
    await worker.run()

Activities

Error Handling

The SDK’s built-in HTTP retries are disabled so Temporal is the single retry authority. Set RetryPolicy on workflow.execute_activity to control backoff and max attempts.

Resources