""" BigQuery Sample DAG with Custom Logging Three tasks: read count from customer table, write to results table, and completion """ # ============================================================================= # IMPORTS # ============================================================================= import os import sys from datetime import datetime , timedelta # Add the current directory to Python path for custom logger import sys . path . append ( os . path . dirname ( os . path . abspath ( __file__ ))) # ============================================================================= # GLOBAL VARIABLES # ============================================================================= GLOBAL_LOGGER = None # ============================================================================= # CONFIGURATION CONSTANTS # ============================================================================= # GCS Configuration GCS_BUCKET_SQL = "test-project"...