diff --git a/tap_salesforce/salesforce/bulk.py b/tap_salesforce/salesforce/bulk.py index 722042da..b31bff49 100644 --- a/tap_salesforce/salesforce/bulk.py +++ b/tap_salesforce/salesforce/bulk.py @@ -23,6 +23,8 @@ def find_parent(stream): parent_stream = stream if stream.endswith("CleanInfo"): parent_stream = stream[:stream.find("CleanInfo")] + elif stream.endswith("FieldHistory"): + parent_stream = stream[:stream.find("FieldHistory")] elif stream.endswith("History"): parent_stream = stream[:stream.find("History")]