From c1e31559df7723490e866fd1fc08012e76f91856 Mon Sep 17 00:00:00 2001 From: marcosschroh Date: Mon, 18 Dec 2023 14:14:22 +0000 Subject: [PATCH] =?UTF-8?q?Deploy=20preview=20for=20PR=20149=20?= =?UTF-8?q?=F0=9F=9B=AB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pr-preview/pr-149/sitemap.xml.gz | Bin 127 -> 127 bytes pr-preview/pr-149/test_client/index.html | 2 +- 2 files changed, 1 insertion(+), 1 deletion(-) diff --git a/pr-preview/pr-149/sitemap.xml.gz b/pr-preview/pr-149/sitemap.xml.gz index 999afc7211c873cd6a9320c2f7278eab640355a3..2c14cfb7be5be6ba0cd803f7e7bba8d3bc909f42 100644 GIT binary patch delta 11 Scmb=gXO-{f;Mg;fwF&?f=L3oW delta 11 Scmb=gXO-{f;Ha3$S_J?T*8@fX diff --git a/pr-preview/pr-149/test_client/index.html b/pr-preview/pr-149/test_client/index.html index e0ff565b..44a4e603 100644 --- a/pr-preview/pr-149/test_client/index.html +++ b/pr-preview/pr-149/test_client/index.html @@ -822,7 +822,7 @@

Defining extra topics

ValueError: You might be trying to get the topic target-topic outside the `client async context` or trying to get an event from an empty topic target-topic. Make sure that the code is inside the async contextand the topic has events. -

We can solve this with a delay (await asyncio.slpeep(...)) inside the async with context to give time to the TestStreamClient to create the topic, however if the buisness logic +

We can solve this with a delay (await asyncio.sleep(...)) inside the async with context to give time to the TestStreamClient to create the topic, however if the buisness logic inside the consume is slow we need to add more delay, then it will become a race condition.

To proper solve it, we can specify to the TestStreamClient the extra topics that we need during the test cycle.

import pytest