[soruce-hubspot] fails on empty timestamp in `ticket_pipelines` stream
- 主要语言
- Python
- 星标
- 22.1k
- 派生
- 5.3k
- PR 合并指标
- PR 指标待抓取
描述
### Connector Name
Hubspot
### Connector Version
v4.6.4
### What step the error happened?
During the sync
### Relevant information
Hi,
Got this error in our Hubspot source: invalid literal for int() with base 10: '', just in one our streams, **ticket_pipelines**

Please let us know if you need more information.
This is also a critical stream for us so we really hope for a quick resolution if possible.
Thanks a lot!
### Relevant log output
```shell
2025-04-25 12:02:33 source ERROR Encountered an exception while reading stream ticket_pipelines
Traceback (most recent call last):
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/sources/abstract_source.py", line 152, in read
yield from self._read_stream(
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/sources/abstract_source.py", line 276, in _read_stream
for record_data_or_message in record_iterator:
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/sources/streams/core.py", line 196, in read
for record_data_or_message in records:
File "/airbyte/integration_code/source_hubspot/streams.py", line 991, in read_records
if self.filter_by_state(stream_state=stream_state, record=record):
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/airbyte/integration_code/source_hubspot/streams.py", line 973, in filter_by_state
self._start_date if str(state_value) == "" else pendulum.from_format(str(state_value), self.cursor_field_datetime_format)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/pendulum/__init__.py", line 259, in from_format
parts = _formatter.parse(string, fmt, now(), locale=locale)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/pendulum/formatting/formatter.py", line 415, in parse
re.sub(pattern, lambda m: self._get_parsed_values(m, parsed, locale, now), time)
File "/usr/local/lib/python3.11/re/__init__.py", line 185, in sub
return _compile(pattern, flags).sub(repl, string, count)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/pendulum/formatting/formatter.py", line 415, in
re.sub(pattern, lambda m: self._get_parsed_values(m, parsed, locale, now), time)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/pendulum/formatting/formatter.py", line 548, in _get_parsed_values
self._get_parsed_value(token, m.group(index), parsed, now)
File "/usr/local/lib/python3.11/site-packages/pendulum/formatting/formatter.py", line 597, in _get_parsed_value
offset = ((int(off_hour) * 60) + int(off_minute)) * 60
^^^^^^^^^^^^^
ValueError: invalid literal for int() with base 10: ''
2025-04-25 12:02:34 source ERROR None
Traceback (most recent call last):
File "/airbyte/integration_code/main.py", line 9, in
run()
File "/airbyte/integration_code/source_hubspot/run.py", line 54, in run
launch(source, _args)
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/entrypoint.py", line 341, in launch
for message in source_entrypoint.run(parsed_args):
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/entrypoint.py", line 171, in run
yield from map(
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/entrypoint.py", line 244, in read
for message in self.source.read(self.logger, config, catalog, state):
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/sources/declarative/concurrent_declarative_source.py", line 172, in read
yield from super().read(logger, config, filtered_catalog, state)
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/sources/declarative/manifest_declarative_source.py", line 256, in read
yield from super().read(logger, config, catalog, state)
File "/usr/local/lib/python3.11/site-packages/airbyte_cdk/sources/abstract_source.py", line 208, in read
raise AirbyteTracedException(
airbyte_cdk.utils.traced_exception.AirbyteTracedException: None
2025-04-25 12:03:41 destination ERROR main i.a.c.i.u.ConnectorExceptionHandler(handleException):68 caught exception! io.airbyte.commons.exceptions.TransientErrorException: Some streams were unsuccessful due to a source error. See logs for details.
at io.airbyte.cdk.integrations.destination.async.AsyncStreamConsumer.close(AsyncStreamConsumer.kt:215) ~[airbyte-cdk-core-0.46.0.jar:?]
at kotlin.jdk7.AutoCloseableKt.closeFinally(AutoCloseableJVM.kt:48) ~[kotlin-stdlib-2.0.0.jar:2.0.0-release-341]
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.kt:215) [airbyte-cdk-core-0.46.0.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.kt:119) [airbyte-cdk-core-0.46.0.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.run$default(IntegrationRunner.kt:113) [airbyte-cdk-core-0.46.0.jar:?]
at io.airbyte.integrations.destination.databricks.DatabricksDestinationKt.main(DatabricksDestination.kt:276) [io.airbyte.airbyte-integrations.connectors-destination-databricks.jar:?]
Stack Trace: io.airbyte.commons.exceptions.TransientErrorException: Some streams were unsuccessful due to a source error. See logs for details.
at io.airbyte.cdk.integrations.destination.async.AsyncStreamConsumer.close(AsyncStreamConsumer.kt:215)
at kotlin.jdk7.AutoCloseableKt.closeFinally(AutoCloseableJVM.kt:48)
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.kt:215)
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.kt:119)
at io.airbyte.cdk.integrations.base.IntegrationRunner.run$default(IntegrationRunner.kt:113)
at io.airbyte.integrations.destination.databricks.DatabricksDestinationKt.main(DatabricksDestination.kt:276)
2025-04-25 12:03:46 platform ERROR Failing job: 34608744, reason: Job failed after too many retries for connection 0af4beed-e90c-4419-b936-cbfb4d099937
```
### Contribute
- [ ] Yes, I want to contribute
贡献指南
评估
这个 Issue 还没有评估数据。