Skip to content
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

Implement async methods in RedisKVStore #12943

Merged

Conversation

philipchung
Copy link
Contributor

Description

Async methods were not implemented in RedisKVStore. This is necessary if RedisKVStore is used as an ingestion cache or docstore in an async ingestion pipeline.

Fixes #10248

Implement async methods.

New Package?

Did I fill in the tool.llamahub section in the pyproject.toml and provide a detailed README.md for my new integration or package?

  • Yes
  • No

Version Bump?

Did I bump the version in the pyproject.toml file of the package I am updating? (Except for the llama-index-core package)

  • Yes
  • No

Type of Change

Please delete options that are not relevant.

  • Bug fix (non-breaking change which fixes an issue)

How Has This Been Tested?

Please describe the tests that you ran to verify your changes. Provide instructions so we can reproduce. Please also list any relevant details for your test configuration

  • I stared at the code and made sure it makes sense
  • Used in my own project code and it works properly

Suggested Checklist:

  • I have performed a self-review of my own code
  • I have commented my code, particularly in hard-to-understand areas
  • I have made corresponding changes to the documentation
  • I have added Google Colab support for the newly added notebooks.
  • My changes generate no new warnings
  • I have added tests that prove my fix is effective or that my feature works
  • New and existing unit tests pass locally with my changes
  • I ran make format; make lint to appease the lint gods

@dosubot dosubot bot added the size:M This PR changes 30-99 lines, ignoring generated files. label Apr 18, 2024

Args:
key (str): key
val (dict): value
collection (str): collection name

"""
raise NotImplementedError
return self.put(key=key, val=val, collection=collection)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should we take the time to actually implement the async method though?

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fake-async will still block the thread

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@philipchung light bump on this

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Unfortunately I don't have time to implement true async methods. I've used this fake async implementation with async ingestion pipeline and have not experienced any major performance degradation for my own use cases.

@logan-markewich
Copy link
Collaborator

Ok, I added the actual async methods (wasn't actually too hard)

@dosubot dosubot bot added the lgtm This PR has been approved by a maintainer label May 10, 2024
@logan-markewich logan-markewich enabled auto-merge (squash) May 10, 2024 17:27
@logan-markewich logan-markewich merged commit e6ffcaa into run-llama:main May 10, 2024
8 checks passed
raghavdixit99 pushed a commit to raghavdixit99/llama_index_lance that referenced this pull request May 11, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
lgtm This PR has been approved by a maintainer size:M This PR changes 30-99 lines, ignoring generated files.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[Bug]: IngestionPipeline 0.9.36 pipline.arun to Redis Not implemented Error
2 participants