Skip to content
This repository was archived by the owner on Aug 25, 2024. It is now read-only.

Commit b2fcf73

Browse files
authored
df: memory: Remove set_items from NotificationSetContext
Fixes: #401
1 parent b1d9f05 commit b2fcf73

File tree

1 file changed

+3
-8
lines changed

1 file changed

+3
-8
lines changed

dffml/df/memory.py

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -152,10 +152,7 @@ def __init__(self, parent: "NotificationSet") -> None:
152152
self.parent = parent
153153
self.logger = LOGGER.getChild(self.__class__.__qualname__)
154154

155-
async def add(self, notification_item: Any, set_items: List[Any]):
156-
"""
157-
Add set_items to set and notification_item to the notification queue
158-
"""
155+
async def add(self, notification_item: Any):
159156
async with self.parent.lock:
160157
self.parent.notification_items.append(notification_item)
161158
self.parent.event_added.set()
@@ -246,12 +243,10 @@ async def add(self, input_set: BaseInputSet):
246243
if not handle_string in self.input_notification_set:
247244
self.input_notification_set[handle_string] = NotificationSet()
248245
async with self.ctx_notification_set() as ctx:
249-
await ctx.add(input_set.ctx, [])
246+
await ctx.add(input_set.ctx)
250247
# Add the input set to the incoming inputs
251248
async with self.input_notification_set[handle_string]() as ctx:
252-
await ctx.add(
253-
input_set, [item async for item in input_set.inputs()]
254-
)
249+
await ctx.add(input_set)
255250
# Associate inputs with their context handle grouped by definition
256251
async with self.ctxhd_lock:
257252
# Create dict for handle_string if not present

0 commit comments

Comments
 (0)