diff --git a/dagger/pipeline/tasks/reverse_etl_task.py b/dagger/pipeline/tasks/reverse_etl_task.py index c0c6290..10c013d 100644 --- a/dagger/pipeline/tasks/reverse_etl_task.py +++ b/dagger/pipeline/tasks/reverse_etl_task.py @@ -104,7 +104,7 @@ def init_attributes(cls, orig_cls): Attribute( attribute_name="full_refresh", parent_fields=["task_parameters"], - validator=bool, + validator=str, required=False, comment="If set to True, the job will perform a full refresh instead of an incremental one", ),