From db31221ddeeeea3f7444c417c7c88f8363d19c1c Mon Sep 17 00:00:00 2001 From: Nathan Tien You Date: Thu, 24 Sep 2026 16:39:11 +0200 Subject: [PATCH] add block diagrams for celery sse communication --- 2026/celery/slides/00-intro.md | 6 +++++- 2026/celery/slides/02-progressbar.md | 14 +++++++++++--- start.sh | 4 +++- 3 files changed, 19 insertions(+), 5 deletions(-) diff --git a/2026/celery/slides/00-intro.md b/2026/celery/slides/00-intro.md index 0c0f9b3..b2745d3 100644 --- a/2026/celery/slides/00-intro.md +++ b/2026/celery/slides/00-intro.md @@ -1,5 +1,9 @@ # Celery - + +https://gricad-gitlab.univ-grenoble-alpes.fr/tienyoun/presentations + + + --- diff --git a/2026/celery/slides/02-progressbar.md b/2026/celery/slides/02-progressbar.md index e726fe0..be36ec7 100644 --- a/2026/celery/slides/02-progressbar.md +++ b/2026/celery/slides/02-progressbar.md @@ -131,6 +131,13 @@ https://docs.celeryq.dev/en/main/reference/celery.events.html +### Coté Worker +- celery.events.EventDispatcher 📢 +- celery.events.EventReceiver 👂 + + + + ### Coté Worker @@ -187,10 +194,10 @@ class PtfTask(AbortableTask): ```python @shared_task(name="crawler.tasks.toto", base=PtfTask, bind=True) def print_toto(self, toto = "toto"): - + meta = {"current": 0, "total": len(toto)} # Initialize progress bar at 0 self.update_state( - meta={"current": index, "total": len(toto)}, + meta=meta, state=states.STARTED, ) @@ -199,8 +206,9 @@ def print_toto(self, toto = "toto"): print(letter) # Update progress bar + meta["current"] = index self.update_state( - meta={"current": index, "total": len(toto)}, + meta=meta, state=states.STARTED, ) ``` diff --git a/start.sh b/start.sh index d7714c8..fe5a733 100755 --- a/start.sh +++ b/start.sh @@ -1,4 +1,6 @@ podman run --rm \ +-e SHOW_NOTES_FOR_PRINTING=true \ -e ADDITIONAL_SCRIPT='' \ -e ADDITIONAL_PLUGINS="RevealMermaid" \ --p 28080:8000 -p 35729:35729 -v $(pwd)/2026/celery/slides:/reveal/docs/slides -v $(pwd)/2026/celery/assets:/reveal/assets cloudogu/reveal.js:dev +-e ADDITIONAL_REVEAL_OPTIONS="center: false," \ +--network=host -v $(pwd)/2026/celery2/slides:/reveal/docs/slides -v $(pwd)/2026/celery2/assets:/reveal/assets cloudogu/reveal.js:dev