Problem with `timed_window` with asyncio
Dieses Issue hat noch niemand übernommen.
Bewertung
- Schwierigkeit
- 4/5
- Geschätzter Aufwand
- 3-5 Tage
- Anfängerfreundlichkeit
- 35/100
- Issue-Typ
- Bug
- Klarheit
- Größtenteils klar
- Aktivitätsstatus
- Veraltet
- Tech-Stack
- python
- Bereich
- stream-processing
Rechercherichtung
Start with the fib_asyncio.py example and the sync function in streamz/core.py around line 1068, then reproduce the timed_window failure with asyncio. Trace how the event loop is checked and verify that the example runs without the reported AttributeError.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Beschreibung
Hi,
When I try to use the timed_window function with the asyncio event loop I get the following error:
AttributeError: 'AsyncIOMainLoop' object has no attribute '_running'
For example if you change line 12 of the `fib_asyncio.py" example to:
s.timed_window(1.0).sink(lambda x: print(x))
then I get:
$ python fib_asyncio.py
Traceback (most recent call last):
File "fib_asyncio.py", line 14, in <module>
source.emit(0) # seed with initial values
File "/opt/venv-numismatic/lib/python3.6/site-packages/streamz/core.py", line 219, in emit
return sync(self.loop, _)
File "/opt/venv-numismatic/lib/python3.6/site-packages/streamz/core.py", line 1068, in sync
if not loop._running:
AttributeError: 'AsyncIOMainLoop' object has no attribute '_running'
- Vorherrschende Sprache
- Python
- Sterne
- 1.3k
- Forks
- 150
- Ø Merge
- 17 Std. 39 Min.
- Gemergte PRs (30 T.)
- 1
Entwicklungsumgebung
- Enthält ein Dockerfile oder eine Docker-Compose-Datei
- Keine Pull-Request-Vorlage
- Beitragsleitfaden lesen
Erste Schritte
- Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
- Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
- Forken Sie das Repository und arbeiten Sie in einem Branch.
- Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.
Mehr aus python-streamz/streamz
-
pkg_resources warningOffen
Schwierigkeit 3/5 1-2 Tage Anfängerfreundlichkeit 35/100
python-streamz/streamz#481 · 4 Kommentare ·
-
Combining the streamz.Stream.filenames() and streamz.Stream.from_textfile() using dask scatter?Offen
Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 25/100
python-streamz/streamz#480 · 2 Kommentare ·
-
Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 20/100
python-streamz/streamz#479 · 1 Kommentar ·
-
Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 20/100
python-streamz/streamz#478 · 6 Kommentare ·
-
Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 10/100
python-streamz/streamz#476 · 17 Kommentare · 2 Reaktionen ·
Alle Issues in python-streamz/streamz
Ähnliche Issues
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 72/100
NousResearch/hermes-agent#136483 ·
Maintainer antworten meist innerhalb von 1 Tag
-
Schwierigkeit 1/5 Unter einer Stunde Anfängerfreundlichkeit 88/100
Maintainer antworten meist innerhalb von 1 Tag
-
[BUG] LazyStackedTensorDictStore zeroes the last byte of a new key set on the last elementEvtl. vergeben @peterdsharpe hat das heute übernommen. Offenbug
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 78/100
pytorch/tensordict#2307 ·
Maintainer antworten meist innerhalb von 1 Tag
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 78/100
Maintainer antworten meist innerhalb von 1 Tag
-
GrokModel.generate/a_generate pass an OpenAI-style list-of-dicts to xai_sdk.chat.user(), so every call crashes with a protobuf TypeError before any network I/OEvtl. vergeben @Christian-Sidak hat das heute übernommen. Offen
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 70/100
confident-ai/deepeval#3436 · 1 Kommentar ·
Maintainer antworten meist innerhalb von 1 Tag