airflow/dags/util.py
def did_gcs_file_download(gcs_download_task_id: str, **kwargs):
    """
    Check the response code of the gcs download step.

    Parameters:
        gcs_download_task_id: the task id of the
        kwargs: remaining named function arguments

    Returns: A boolean indication that a file was downloaded
    """
    response_code = kwargs['ti'].xcom_pull(
        key=None, task_ids=gcs_download_task_id)
    return response_code == HTTPStatus.CREATED

    Check the response code of the gcs download step.

    Parameters:
        gcs_download_task_id: the task id of the
        kwargs: remaining named function arguments

    Returns: A boolean indication that a file was downloaded
    
Check the response code of the gcs download step.
Check the response code of the gcs download step .
def did_gcs_file_download(gcs_download_task_id: str, **kwargs):
    response_code = kwargs['ti'].xcom_pull(
        key=None, task_ids=gcs_download_task_id)
    return response_code == HTTPStatus.CREATED
def did_gcs_file_download ( gcs_download_task_id : str , ** kwargs ) : response_code = kwargs [ 'ti' ] . xcom_pull ( key = None , task_ids = gcs_download_task_id ) return response_code == HTTPStatus . CREATED
Check the response code of the gcs download step.
Check the response code of the gcs download step .
"""
    Check the response code of the gcs download step.

    Parameters:
        gcs_download_task_id: the task id of the
        kwargs: remaining named function arguments

    Returns: A boolean indication that a file was downloaded
    """
gcs_download_task_id
str
the task id of the
the task id of the
kwargs
remaining named function arguments
remaining named function arguments