Function _init_forward_context

backend/data_process/tasks.py:398–416

(
    *,
    task_id: str,
    request_id: str,
    start_time: float,
    source: str,
    index_name: str,
    source_type: str,
    original_filename: Optional[str],
)

def _init_forward_context(
    *,
    task_id: str,
    request_id: str,
    start_time: float,
    source: str,
    index_name: str,
    source_type: str,
    original_filename: Optional[str],
) -> _ForwardContext:
    return _ForwardContext(
        task_id=task_id,
        request_id=request_id,
        start_time=start_time,
        source=source,
        index_name=index_name,
        source_type=source_type,
        original_filename=original_filename,
    )


def _is_forward_task_cancelled(ctx: _ForwardContext) -> bool: