Skip to content

Commit 525e671

Browse files
authored
sources: Ensure different topic for each DummySource (#532)
1 parent b36cc94 commit 525e671

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

tests/utils.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import dataclasses
22
import time
3+
import uuid
34
import threading
45

56
from typing import Optional, Tuple, Union, List, Any
@@ -124,13 +125,13 @@ def total_batched(self) -> int:
124125
class DummySource(Source):
125126
def __init__(
126127
self,
127-
name="dummy",
128+
name: Optional[str] = None,
128129
values: Optional[List[Any]] = None,
129130
finished: threading.Event = None,
130131
error_in: Union[str, List[str]] = None,
131132
pickeable_error: bool = True,
132133
) -> None:
133-
super().__init__(name, 1)
134+
super().__init__(name or str(uuid.uuid4()), 1)
134135

135136
self.key = "dummy"
136137
self.values = values or []

0 commit comments

Comments
 (0)