deep research agent deadline_exceeded

[zhushanwei]

client = genai.Client()
initial_stream = client.interactions.create(
input=prompt,
agent='deep-research-pro-preview-12-2025',
background=True,
stream=True,
agent_config={
"type": "deep-research",
"thinking_summaries": "auto"
}
)
for event in event_stream:
print(event)

The following error occurred. Which parameters need to be modified? Thanks

ErrorEvent(error=Error(code='deadline_exceeded', message=''), event_id=None, event_type='error')

[zhushanwei]

initial_stream = client.interactions.create(
input=prompt,
agent=agent_name,
background=True,
stream=True,
timeout=600,
agent_config={
"type": "deep-research",
"thinking_summaries": "auto"
}
) The timeout parameter was added, but it didn't work.

[janasangeetha]

Hey @zhushanwei
I tried the code shared by you and did not observe any error. Please find the gist.

[zhushanwei]

@janasangeetha May I ask how long your agent runs? I've noticed that this problem tends to occur when the running time exceeds 5 minutes.

[janasangeetha]

@zhushanwei The agent ran for around 3 minutes. Could you please share the prompt so that I can reproduce from my end?
Thank you!

[zhushanwei]

@janasangeetha Thank you for your reply. Below is my code:

import time
from google import genai
from google.genai.types import HttpOptions

client = genai.Client(api_key='xxxxxx', http_options=HttpOptions(
                        base_url='https://generativelanguage.googleapis.com', timeout=1200000)
                      )

# Configuration
agent_name = 'deep-research-pro-preview-12-2025'

prompt = f"""
        User Question: Large Language Model Industry Report

        Requirements:
        1. **Role:** You are an expert and need to write a complete report based on the user's question.
        2. **Markdown Format:** The final output must be in Markdown format, ensuring clear structure and aesthetically pleasing layout, but without starting with ```markdown and ending with ```.
        3. The entire report should be approximately 10,000 words.
        4. **Language:** You need to determine which language to use for the report based on the user's question or language.
        5. **Citations:** Use the format [cite: 1], [cite: 3, 4] for citations in the report.
        6. **Citation Sources:** At the end of the report, use **Sources:** to list all citation sources completely, in the following format:
        **Sources:**
        1. [wikipedia.org](https://vertexaisearch.cloud.google.com/grounding-api-redirect/AUZIYQH1OW2BpHd2XHd2VAyVbFKDvZyya9Iz6YgjMXlBa3h95DjHwtaVKBi53U8RwsJzJZh_8dLohrJJmr5MVuUhITQwPzFuUUlXaM7ANJlrwlz8u0DNsejwmvEEuHRPFmTGPgN8cSOpCkzZSX9giIqxrBZ6)
        2. [investopedia.com](https://vertexaisearch.cloud.google.com/grounding-api-redirect/AUZIYQEB2j0hoJXWkvxFVIhmvVajFMIA_rtKi0bdeHSbO-xCsQtm7233HqfCmYmxZmWYUD2dwDGKnSgjFvqzloXp4jc5ecY7WuAlg7Fzq2ZMV1u3_s-LoTGW-3H-UYJWDmZ02h_BtMq-fLtEiFKhi6uZaYqsURWWH01GYJEcrDYcISTdPqoe8eTT1k4ZVLrMnlJmUc_0Fwb-lzoCla7yAgr5Gmk=)
        ...
"""

# State tracking
last_event_id = None
interaction_id = None
is_complete = False


def process_stream(event_stream):
    """Helper to process events from any stream source."""
    global last_event_id, interaction_id, is_complete
    for event in event_stream:
        print(f"event:{str(event)}")
        # Capture Interaction ID
        if event.event_type == "interaction.start":
            interaction_id = event.interaction.id
            print(f"Interaction started: {interaction_id}")

        # Capture Event ID
        if event.event_id:
            last_event_id = event.event_id

        # Print content
        if event.event_type == "content.delta":
            if event.delta.type == "text":
                print(event.delta.text, end="", flush=True)
            elif event.delta.type == "thought_summary":
                print(f"Thought: {event.delta.content.text}", flush=True)

        # Check completion
        if event.event_type in ['interaction.complete', 'error']:
            is_complete = True


# 1. Attempt initial streaming request
try:
    print("Starting Research...")
    initial_stream = client.interactions.create(
        input=prompt,
        agent=agent_name,
        background=True,
        stream=True,
        timeout=600,
        agent_config={
            "type": "deep-research",
            "thinking_summaries": "auto"
        }
    )
    process_stream(initial_stream)
except Exception as e:
    print(f"\nInitial connection dropped: {e}")

# 2. Reconnection Loop
# If the code reaches here and is_complete is False, we resume using .get()
while not is_complete and interaction_id:
    print(f"\nConnection lost. Resuming from event {last_event_id}...")
    time.sleep(2)

    try:
        resume_stream = client.interactions.get(
            id=interaction_id,
            stream=True,
            timeout=600,
            last_event_id=last_event_id
        )
        process_stream(resume_stream)
    except Exception as e:
        print(f"Reconnection failed, retrying... ({e})")

[janasangeetha]

@zhushanwei Thanks for sharing the code.
I was able to reproduce. Will file a bug internally.