Skip to content

Investigate/replace use of thread local in ActiveBulkThread #38705

@ormsbee

Description

@ormsbee

The following is not async-safe:

class ActiveBulkThread(threading.local):
"""
Add the expected vars to the thread.
"""
def __init__(self, bulk_ops_record_type, **kwargs):
super().__init__(**kwargs)
self.records = defaultdict(bulk_ops_record_type)

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions