-
Notifications
You must be signed in to change notification settings - Fork 6
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
Ingest edgelists #1
Conversation
with concurrent.futures.ThreadPoolExecutor( | ||
_N_PARALLEL_REQUESTS | ||
) as executor: | ||
result_futures = list( |
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.
Is there some built in error handling with the ThreadPoolExecutor should the dynamo writes fail?
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.
That there is not! I think I need to handle this at the iterator over result_futures
, though really i feel like I'm still doing this so wrong... is there really no way to batch inserts faster than one-by-one?!
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.
No, I think you do have to do one-by-one unless they added a new API call since I last worked with Dynamo (which may have been last year).
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.
😭 Adding an issue for this!
No description provided.