Merge pull request airbytehq#8 from mohamagdy/destination-redshift-no…

…-dbt Filter out `None` items
mohamagdy · Apr 8, 2022 · 1dc530b · 1dc530b
2 parents 6f87d6c + f7fedce
commit 1dc530b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/airbyte-integrations/connectors/destination-redshift-no-dbt/Dockerfile b/airbyte-integrations/connectors/destination-redshift-no-dbt/Dockerfile
@@ -36,5 +36,5 @@ COPY destination_redshift_no_dbt ./destination_redshift_no_dbt
 ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
 ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
 
-LABEL io.airbyte.version=0.1.2
+LABEL io.airbyte.version=0.1.3
 LABEL io.airbyte.name=airbyte/destination-redshift-no-dbt
diff --git a/...rations/connectors/destination-redshift-no-dbt/destination_redshift_no_dbt/destination.py b/...rations/connectors/destination-redshift-no-dbt/destination_redshift_no_dbt/destination.py
@@ -119,6 +119,8 @@ def get_records(parents: Union[DotMap, List[DotMap]], method: str) -> List[DotMa
                         if not isinstance(parents, list):
                             parents = [parents]
 
+                        parents = list(filter(None, parents))
+
                         children_records = []
                         for parent_item in parents:
                             children = parent_item.get(method)
@@ -129,7 +131,6 @@ def get_records(parents: Union[DotMap, List[DotMap]], method: str) -> List[DotMa
                                 if child_item and final_table.references and method == node[-1]:
                                     child_item[final_table.reference_key.name] = parent_item[AIRBYTE_ID_NAME]
 
-
                                 children_records.append(child_item)
 
                         return children_records