diff --git a/tap_pipedrive/tap.py b/tap_pipedrive/tap.py index 536d5c8..37cd1c9 100644 --- a/tap_pipedrive/tap.py +++ b/tap_pipedrive/tap.py @@ -57,7 +57,7 @@ def do_discover(self): metadata = [] for prop, json_schema in schema.properties.items(): inclusion = 'available' - if prop in key_properties: + if prop in key_properties or (stream.state_field and prop == stream.state_field): inclusion = 'automatic' metadata.append({ 'breadcrumb': ['properties', prop],