diff --git a/providers/salesforce/src/airflow/providers/salesforce/hooks/salesforce.py b/providers/salesforce/src/airflow/providers/salesforce/hooks/salesforce.py index 9368cd40c5bbe..ff9996cb9f1d2 100644 --- a/providers/salesforce/src/airflow/providers/salesforce/hooks/salesforce.py +++ b/providers/salesforce/src/airflow/providers/salesforce/hooks/salesforce.py @@ -345,7 +345,7 @@ def write_object_to_file( elif fmt == "json": df.to_json(filename, orient="records", date_unit="s") elif fmt == "ndjson": - df.to_json(filename, orient="records", lines=True, date_unit="s") + df.to_json(filename, orient="records", date_unit="s", lines=True) return df