-
Notifications
You must be signed in to change notification settings - Fork 4.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
fixed bug which crashes okta log incremental sync #7584
Conversation
@@ -82,17 +83,22 @@ def cursor_field(self) -> str: | |||
pass | |||
|
|||
def get_updated_state(self, current_stream_state: MutableMapping[str, Any], latest_record: Mapping[str, Any]) -> Mapping[str, Any]: | |||
lowest_date = str(pendulum.datetime.min) | |||
lowest_date = str(datetime.min) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why this change from pendulum to datetime?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
pendulum.datetime.min wasn't resolving on my machine.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
you need to run tests with pyenv activated
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I reverted it back to pendulum
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thanks @collinscangarella
* fixed bug which crashes okta log incremental sync * bump connector version * revert to pendulum
* fixed bug which crashes okta log incremental sync * bump connector version * revert to pendulum
What
Okta logs failed when doing an incremental sync.
How
The logs endpoint uses different filtering from the users and groups endpoints. Instead of using a query param called
filter
, it uses a query param calledsince
. Here's Okta's documentation on this.Recommended reading order
airbyte-integrations/connectors/source-okta/source_okta/source.py
airbyte-integrations/connectors/source-okta/integration_tests/configured_catalog.json
Pre-merge Checklist
Expand the relevant checklist and delete the others.
Updating a connector
Community member or Airbyter
airbyte_secret
./gradlew :airbyte-integrations:connectors:<name>:integrationTest
.README.md
bootstrap.md
. See description and examplesdocs/integrations/<source or destination>/<name>.md
including changelog. See changelog exampleAirbyter
If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.
/test connector=connectors/<name>
command is passing./publish
command described here