Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
11-05-2024 08:10 AM
You can use the following code:
pipeline_run_config = get_current_pipeline_run_config()
# Create a StartUpdate object from the pipeline run configuration
start_update = StartUpdate.from_dict(pipeline_run_config)
# Check if the pipeline run is a full refresh
if start_update.full_refresh:
print("The pipeline is running in Full Refresh mode.")
else:
print("The pipeline is running in Incremental mode.")