From 78af103621713b2be523ee32910db6e0d6cf5cdb Mon Sep 17 00:00:00 2001
From: Rohit Chatterjee <rohit@rootbridgeservices.in>
Date: Thu, 30 May 2024 23:23:49 +0530
Subject: [PATCH] don't filter on form_ids

---
 .../source-commcare/source_commcare/source.py | 25 +++++++++----------
 1 file changed, 12 insertions(+), 13 deletions(-)

diff --git a/airbyte-integrations/connectors/source-commcare/source_commcare/source.py b/airbyte-integrations/connectors/source-commcare/source_commcare/source.py
index 8327fa842264..37c601ccc10c 100644
--- a/airbyte-integrations/connectors/source-commcare/source_commcare/source.py
+++ b/airbyte-integrations/connectors/source-commcare/source_commcare/source.py
@@ -197,19 +197,18 @@ def request_params(
 
     def read_records(self, *args, **kwargs) -> Iterable[Mapping[str, Any]]:
         for record in super().read_records(*args, **kwargs):
-            if any(f in CommcareStream.forms for f in record["xform_ids"]):
-                self._cursor_value = parse_datetime_with_microseconds(record[self.cursor_field])
-                # Make indexed_on tz aware
-                record.update({"streamname": "case", "indexed_on": ensure_single_trailing_Z(record["indexed_on"])})
-                # convert xform_ids field from array to comma separated list so flattening won't create
-                # one field per item. This is because some cases have up to 2000 xform_ids and we don't want 2000 extra
-                # fields in the schema
-                record["xform_ids"] = ",".join(record["xform_ids"])
-                retval = {}
-                retval["id"] = record["id"]
-                retval["indexed_on"] = ensure_single_trailing_Z(record["indexed_on"])
-                retval["data"] = record
-                yield retval
+            self._cursor_value = parse_datetime_with_microseconds(record[self.cursor_field])
+            # Make indexed_on tz aware
+            record.update({"streamname": "case", "indexed_on": ensure_single_trailing_Z(record["indexed_on"])})
+            # convert xform_ids field from array to comma separated list so flattening won't create
+            # one field per item. This is because some cases have up to 2000 xform_ids and we don't want 2000 extra
+            # fields in the schema
+            record["xform_ids"] = ",".join(record["xform_ids"])
+            retval = {}
+            retval["id"] = record["id"]
+            retval["indexed_on"] = ensure_single_trailing_Z(record["indexed_on"])
+            retval["data"] = record
+            yield retval
 
         if self._cursor_value and self._cursor_value.microsecond == 0:
             # Airbyte state handling adjustment