Watcher SDK

Getting Started

  • Quick Start Guide
    • Installation
    • Usage
      • Store Pipeline and Address Lineage Configuration
      • Sync Pipeline and Address Lineage Configuration
      • Track Pipeline Execution

API

  • Core Models
    • ETLResult
    • WatcherContext
    • ExecutionResult
  • Pipeline Configuration
    • Pipeline
    • PipelineConfig
    • SyncedPipelineConfig
  • Address Lineage
    • Address
    • AddressLineage
  • Error Handling
    • WatcherAPIError
    • WatcherNetworkError

Guides

  • Address Management
    • Address Lineage Configuration
    • Loading Address Lineage
  • Authentication
    • Overview
    • Supported Cloud Environments
    • Basic Usage
    • Explicit Authentication Configuration
    • Cloud-Specific Configuration
    • Environment Variables
    • Installation with Cloud Dependencies
    • Orchestration Integration
    • Error Handling
    • Common Issues
    • Best Practices
    • Example: Complete Cloud Deployment
  • Execution Management
    • Logging Executions
      • Exception Handling
      • Example Usage
    • Custom ETL Results
    • ETL Results
    • Execution Results
    • Hierarchical Executions
    • Watcher Execution Context
    • Active Flag
    • Manual Execution Management
  • Monitoring
    • Trigger Timeliness Check
    • Trigger Freshness Check
    • Trigger Celery Queue Check
  • Orchestration Integration
    • Overview
    • Basic Usage
    • Dagster Integration
    • Airflow Integration
    • Advanced Usage
      • Watermark Management
      • Context Detection
      • Metadata Injection
    • Error Handling
    • Best Practices
      • Example: Complete Dagster Pipeline with Parent Execution Tracking
      • Example: Complete Airflow DAG with Parent Execution Tracking
  • Watermark Management
    • Incrementing Watermarks
    • Accessing Watermarks
    • Watermark Data Type
Watcher SDK
  • Search

© Copyright 2025, Cortland Goffena.

Built with Sphinx using a theme provided by Read the Docs.