Analyze a sample of frames to detect the actual product boundaries. Returns the bounding box that encompasses the product across all sampled fram

Mocked execution of BigQuery queries to bypass GCP Dataset NotFound errors. Args: project: The Google Cloud project ID. query: Th

Filter and return up to 4 images in order: right, left, front, back. Selection priority: - 1st (right): right, front_right, back_right -

Detect the frame where a target color's ratio drops significantly and stabilizes. This is useful for finding the first frame after a greenscreen

Recursively finds files in a given directory that match a specified regex pattern. This function uses the Unix `find` command to search for

Generate a description of the product from images using Gemini. Generalized version for any product (not just footwear). Args: clien

Generates a string of sample values from metadata.

Calculates the date for the start of a time span relative to now. Args: time_span: The time span to calculate. Options: 'week', 'mon

Get a configured GCS client.

Return GEMINI_PRO_MODEL from env (deferred for Agent Engine compatibility).

Determine which page (i.e. item_page, search_results) the given URL is pointing at.

Convert input to appropriate Gemini Part type. Handles text, image/video bytes, and GCS paths. Auto-detects MIME type.

Get the current status of a process.

Safely retrieves a layout using keyword-based mapping.

Returns a list of all scheduled periods from finalized and draft rosters. Only includes rosters that still have their roster file. Retur

Check if an error message indicates an infrastructure failure.

Check if the video path is valid. Args: video_path: List of class labels for each frame. strict: Whether to use strict path valid

Load master data from a YAML or JSON file. Args: path: Path to master_data.yaml (or .json). If None, looks for the defa

Parse the Line Items field (stored as JSON string in the schema).

Select the images for each available ordered side. In case of duplication, it selects the most complete image (highest non-white pixel count).

Preprocess face image: crop face, upscale, then remove background. Args: client: Gemini client instance img_bytes (bytes): The in

Helper function to print the JSON representation of a response.

Renders a presentation from a spec, using a template if provided or falling back to a default style. Saves to a temp file and returns the pat

Sample frames from the video at a target rate. Args: frame_list: List of frames. target_samples_per_sec: Target number of samples

Select the best 4 images for R2V spinning from any number of inputs. Classifies product type and views in one call, then selects based on type:

Convert a document to a target format using LibreOffice headless. Args: file_path: Path to the source file (.ppt, .pptx, .doc, .docx, .rt

Convenience wrapper: convert any document to PDF.

Analyzes the code using AST to detect potentially unsafe operations. Returns a list of error messages if unsafe patterns are found.

GetOrCreateTrip ensures a trip exists for the given ADK session ID and user.

NewSQLStore creates a new SQLStore with the given database connection.

NewTripsHandler initializes a new TripsHandler with the given dependencies.

UpdateItem updates a specific item's status and details, using an UPSERT to prevent duplicates.

Analyzes why the roster cannot be generated and provides solutions. Returns a detailed report with: - Capacity analysis (total shifts vs

Calculate fatigue score based on nurse stats. 0.0 = Fresh, 1.0 = Burnout risk

Call LLM for group validation.

Collect mismatch strings for a list of field labels from a comparison section.

Decode base64 to bytes, or pass through gs:// URIs as-is.

Internal synchronous implementation of Deep Research with retry logic. Follows Vertex AI Deep Research API SDK best practices.

Evaluates a list, set, or dict comprehension. Args: generators: The AST nodes representing the comprehension generators. elts: Th

Check if a field was referenced from a specific source in agent output.

Generate images sequentially with fix attempts, up to max_retries. Flow per attempt: 1. Generate 1 image -> evaluate 2. If score == 1

Gets the Model Armor response for the given text and method.

Returns the string representation of a type. Args: type_: The type to convert to a string. Returns: The string representatio

Returns the string representation of a type. Args: type_: The type to convert to a string. Returns: The string representatio

Handle rejection at a specific validation phase.

Helper to process simulation results, log execution, and format the report.

Check if a new result is better than current best. Non-discarded always beats discarded.

Check if a shift is a night shift (starts at 20:00+ or before 06:00).

Load a list of field dicts into the given instance attribute.

Load HRIS data.

Helper to parse the Deep Research SSE stream. Returns: (report_text, citations_list, interaction_id)

Create/truncate the chunks staging table for this run.

Standardize a mask into a binary 8-bit, single-channel image (values 0 or 255). Crucial for ensuring OpenCV functions work predictably.

Per-run staging name so concurrent pipeline runs don't clobber each other. If a run crashes the table is left behind under its run_id — easier

Helper function to process a log iterator and collect log entries.

Look up the Cloud Run service endpoint via the Run admin API. We prefer this over hard-coding because the Cloud Run hash component in the URL

Split a PDF into individual page bytes and extract raw text per page.

Appends a progress bar to the agent's response.

Fetches Campaign Finance (FEC) contribution data for a specific state. Provides site selection agents with a metric for political stability a

Append a Content or LlmResponse to the GCS-backed conversation history. Args: global_session_id: The stable session UUID. data: A

Call Gemini API with optional structured output

Classify whether a document is relevant for the knowledge base. Args: content: The extracted text content of the document. genai_

Classify the rotation direction of a spinning product video. Args: video_path: Path to the video file (mp4, etc.) config: Optiona

Classify the video generation status based on available views. Args: labels: List of class labels. Returns: list or str: Lis

Clean LLM JSON response - remove markdown, fix trailing commas

Recursively converts protobuf objects (including Structs and RepeatedComposites) into standard Python dictionaries and lists.

Copy a file from the host to a destination in the container.

Create a new event in the calendar.

Create a new file. If the directory does not exist, it will be created. Args: file_path: The path of the new file (relative to the

Helper function to create the payload for sending a message.

Use Gemini vision to generate a short product description of the glasses. Captures brand name, frame shape, frame color, lens type, and any visib

Discover rules from rules book. Uses cache if available and valid. Args: force_refresh: If True, bypass cache and re

Download a file from Google Cloud Storage.