The following bit of code is the problem.
checkpointer_key_name = normalized_input_name
current_checkpoint = (
kvstore_checkpointer.get(checkpointer_key_name)
or datetime(1970, 1, 1).timestamp()
)
on first run, if there is no checkpoint, the api is polled for all data since 1970. This creates problems in production environments as too much data causes genesys to suspend the oauth client so no more conversation metrics API calls can be made till the oauth client is re-enabled
the workaround is to manually create the kvstore checkpoint with an epoch timestamp record before creating the input. not ideal, but ok if you know about it beforehand
The following bit of code is the problem.
on first run, if there is no checkpoint, the api is polled for all data since 1970. This creates problems in production environments as too much data causes genesys to suspend the oauth client so no more conversation metrics API calls can be made till the oauth client is re-enabled
the workaround is to manually create the kvstore checkpoint with an epoch timestamp record before creating the input. not ideal, but ok if you know about it beforehand