I am working on getting my connector updated with passing integration tests, so it can be contributed back to source. Currently all of the tests are passing except test_state_with_abnormally_large_values
. The assertion that a STATE
message is produced is failing.
The code is working in production and when I run it locally state is produced and printed to console. I have tried modifying the state_checkpoint_interval
, but that has not resolved it. Here is my get_updated_state
method.
Any guidance on where I am going wrong?
Test Log:
self = <source_acceptance_test.tests.test_incremental.TestIncremental object at 0x10820b9a0>
connector_config = SecretDict(******)
configured_catalog = ConfiguredAirbyteCatalog(streams=[ConfiguredAirbyteStream(stream=AirbyteStream(name='cash_flows', json_schema={'type':...estination_sync_mode=<DestinationSyncMode.append: 'append'>, primary_key=None, source_defined_primary_key=[['uuid']])])
future_state = {'cash_flows': {'updateDateTime': '9999-05-04T18:31:18Z'}}
docker_runner = <source_acceptance_test.utils.connector_runner.ConnectorRunner object at 0x10820b340>
def test_state_with_abnormally_large_values(self, connector_config, configured_catalog, future_state, docker_runner: ConnectorRunner):
configured_catalog = incremental_only_catalog(configured_catalog)
output = docker_runner.call_read_with_state(config=connector_config, catalog=configured_catalog, state=future_state)
records = filter_output(output, type_=Type.RECORD)
states = filter_output(output, type_=Type.STATE)
assert not records, "The sync should produce no records when run with the state with abnormally large values"
> assert states, "The sync should produce at least one STATE message"
E AssertionError: The sync should produce at least one STATE message
E assert []
../../bases/source-acceptance-test/source_acceptance_test/tests/test_incremental.py:112: AssertionError
airbyte-integrations/bases/source-acceptance-test/source_acceptance_test/tests/test_incremental.py::TestIncremental.test_state_with_abnormally_large_values[inputs0] ⨯100% ██████████
{"type": "LOG", "log": {"level": "INFO", "message": "/Users/willwatkinson/src/github.com/airbytehq/airbyte/airbyte-integrations/connectors/source-kyriba - SAT run - eba6694ac1b24cbf97a0ffba76036b452a8eec13 - FAILED"}}