diff --git a/airbyte-integrations/connectors/source-surveycto/source_surveycto/source.py b/airbyte-integrations/connectors/source-surveycto/source_surveycto/source.py index 67d27eec9900..2a78eb9b6569 100644 --- a/airbyte-integrations/connectors/source-surveycto/source_surveycto/source.py +++ b/airbyte-integrations/connectors/source-surveycto/source_surveycto/source.py @@ -34,10 +34,12 @@ }, } + class SurveyStream(HttpStream, ABC): transformer: TypeTransformer = TypeTransformer(TransformConfig.DefaultSchemaNormalization) def __init__(self, config: Mapping[str, Any], form_id, schema, **kwargs): + self.form_id = None super().__init__() self.config = config @@ -76,7 +78,8 @@ def state(self) -> Mapping[str, Any]: @state.setter def state(self, value: Mapping[str, Any]): - self._cursor_value = value[self.cursor_field] + if self.cursor_field in value: + self._cursor_value = value[self.cursor_field] @property def name(self) -> str: