diff --git a/airbyte-integrations/connectors/source-hubspot/source_hubspot/streams.py b/airbyte-integrations/connectors/source-hubspot/source_hubspot/streams.py index ce5aec1f55c4..02c5947bf252 100644 --- a/airbyte-integrations/connectors/source-hubspot/source_hubspot/streams.py +++ b/airbyte-integrations/connectors/source-hubspot/source_hubspot/streams.py @@ -849,7 +849,7 @@ def next_page_token(self, response: requests.Response) -> Optional[Mapping[str, # https://developers.hubspot.com/docs/api/crm/search. We stop getting data at 10,000, so that # the new sync starts a new query with a more recent cursor value. after = int(response["paging"]["next"]["after"]) - if after < 10000: + if not self.state or after < 10000: params["after"] = after payload["after"] = after return {"params": params, "payload": payload}