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
Fix SSL errors after forking process #1353
Conversation
Codecov ReportPatch coverage:
Additional details and impacted files@@ Coverage Diff @@
## master #1353 +/- ##
==========================================
- Coverage 79.81% 79.73% -0.09%
==========================================
Files 277 277
Lines 13592 13602 +10
==========================================
- Hits 10849 10845 -4
- Misses 2743 2757 +14
Flags with carried forward coverage won't be shown. Click here to find out more.
☔ View full report in Codecov by Sentry. |
69ff96f
to
7e15539
Compare
@staticmethod | ||
def _init_data_path(container_id: UniqueId, container_type: ContainerType): | ||
now = datetime.now() | ||
container_dir = f"{NEPTUNE_DATA_DIRECTORY}/{ASYNC_DIRECTORY}/{container_type.create_dir_name(container_id)}" | ||
data_path = f"{container_dir}/exec-{now.timestamp()}-{now.strftime('%Y-%m-%d_%H.%M.%S.%f')}" | ||
data_path = f"{container_dir}/exec-{os.getpid()}-{now.timestamp()}-{now.strftime('%Y-%m-%d_%H.%M.%S.%f')}" |
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.
Let's move the process id to the end. Currently, it breaks "sorting" capabilities :D.
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.
Done.
src/neptune/internal/operation_processors/async_operation_processor.py
Outdated
Show resolved
Hide resolved
No need to register at fork in HostedNeptuneBackendApiClient and HostedAlphaLeaderboardApiClient.
|
@PatrykGala it's a legacy API. I don't want to touch its behaviour without a good reason. I think it does not even use async processing and Run objects. |
@@ -143,6 +148,37 @@ def __init__( | |||
|
|||
self._startup(debug_mode=mode == Mode.DEBUG) | |||
|
|||
os.register_at_fork(after_in_child=self._handle_fork_in_child, after_in_parent=self._handle_fork_in_parent) | |||
|
|||
""" |
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.
Can we move this comment to reset_internal_ssl_state
as well?
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.
Done.
This reverts commit 4d57e74.
No description provided.