As an addition to this topic. I do have an Account stream in my def streams function like
def streams(self, config: Mapping[str, Any]) -> List[Stream]:
gateway_url = self.gateway_url(config)
client = RobinAuthenticator(config["username"], config["password"], gateway_url)
kwargs = {
"gateway_url": gateway_url,
"client": client,
"start_date": config.get("start_date"),
}
return [
Accounts(**kwargs),
]
and source.py set up like
class Accounts(RobinOdataStream):
primary_key = "UniqueId"
use_cache = True
def path(self, **kwargs) -> str:
return ""
Also the entire log file is saying:
{"type": "LOG", "log": {"level": "INFO", "message": "Starting syncing SourceRobinOdata"}}
{"type": "LOG", "log": {"level": "INFO", "message": "Syncing stream: accounts "}}
{"type": "LOG", "log": {"level": "INFO", "message": "Backing off _send(...) for 5.0s (airbyte_cdk.sources.streams.http.exceptions.DefaultBackoffException: Request URL: https://api.robinhq.com/odata/accounts, Response Code: 571, Response Text: )"}}
{"type": "LOG", "log": {"level": "INFO", "message": "Caught retryable error 'Request URL: https://api.robinhq.com/odata/accounts, Response Code: 571, Response Text: ' after 1 tries. Waiting 5 seconds then retrying..."}}
{"type": "RECORD", "record": {"stream": "accounts", "data": {**[deleted for privacy purposes]**}, "emitted_at": 1663603385702}}
**[240 more records]**
Not more than 1000 rows found
{"type": "LOG", "log": {"level": "INFO", "message": "Read 241 records from accounts stream"}}
{"type": "LOG", "log": {"level": "INFO", "message": "Finished syncing accounts"}}
{"type": "LOG", "log": {"level": "INFO", "message": "SourceRobinOdata runtimes:\nSyncing stream accounts 0:00:07.228217"}}
{"type": "LOG", "log": {"level": "FATAL", "message": "\"The requested stream categories was not found in the source. Available streams: dict_keys(['accounts'])\"\nTraceback (most recent call last):\n File \"main.py\", line 13, in <module>\n launch(source, sys.argv[1:])\n File \"/Users/ricardo/airbyte/airbyte-integrations/connectors/source-robin-odata/.venv/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py\", line 127, in launch\n for message in source_entrypoint.run(parsed_args):\n File \"/Users/ricardo/airbyte/airbyte-integrations/connectors/source-robin-odata/.venv/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py\", line 118, in run\n for message in generator:\n File \"/Users/ricardo/airbyte/airbyte-integrations/connectors/source-robin-odata/.venv/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py\", line 108, in read\n f\"The requested stream {configured_stream.stream.name} was not found in the source.\"\nKeyError: \"The requested stream categories was not found in the source. Available streams: dict_keys(['accounts'])\""}}