diff --git a/airbyte-integrations/connectors/source-kobotoolbox/source_kobotoolbox/source.py b/airbyte-integrations/connectors/source-kobotoolbox/source_kobotoolbox/source.py index ffddd97ea237..4d590bc988b7 100644 --- a/airbyte-integrations/connectors/source-kobotoolbox/source_kobotoolbox/source.py +++ b/airbyte-integrations/connectors/source-kobotoolbox/source_kobotoolbox/source.py @@ -172,6 +172,7 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp retval = {"_id": record["_id"], "data": record} retval["_submission_time"] = record["_submission_time"] retval["endtime"] = record.get("endtime") + retval["end"] = record.get("end") if retval["endtime"]: # endtime is in utc endtime = self.mk_tzaware_utc(datetime.fromisoformat(retval["endtime"]))