From fd236f806a763b4a5183d51e5d4c0dea36f7aed9 Mon Sep 17 00:00:00 2001
From: Murat Aslan <78961478+murataslan1@users.noreply.github.com>
Date: Wed, 28 Jan 2026 03:08:10 +0300
Subject: [PATCH] fix: update outdated examples in openbb-apachebeam (#7286)

- examples/openbb-apachebeam/README.md: Fix test-run command to point to example tests directory, fix typos and grammar
- examples/openbb-apachebeam/requirements.txt: Add core 'openbb' dependency required by example
- examples/openbb-apachebeam/tests/test_obb_pipeline.py: Fix code formatting, fix 'Print nes' typo to 'Print news'

Fixes #7181

Co-authored-by: Murat Aslan <murataslan1@users.noreply.github.com>
Co-authored-by: Danglewood <85772166+deeleeramone@users.noreply.github.com>
---
 examples/openbb-apachebeam/README.md          | 15 ++++-----
 .../tests/test_obb_pipeline.py                | 31 ++++++++++++-------
 2 files changed, 28 insertions(+), 18 deletions(-)

diff --git a/examples/openbb-apachebeam/README.md b/examples/openbb-apachebeam/README.md
index 3e2d1d4ad21..bd4f8ee2457 100644
--- a/examples/openbb-apachebeam/README.md
+++ b/examples/openbb-apachebeam/README.md
@@ -1,12 +1,13 @@
 # OBB Dataflow Sample
 
+This is a sample on how to invoke OBB fetchers in an Apache Beam pipeline. (GCP Dataflow is built on Apache Beam)
 
-This is a sample how to  invoke OBB fetchers in an Apache Beam pipeline. (GCP dataflow is build on Apache Beam)
 Pre-requisites
-- You need to create a Conda environment (or a virtual env) using requirements.txt in this directory
-- The script exercise 3 OBB endpoints, all of which require no credentials
-- Run the test from the main directory
-  python -m unittest .\tests\test_obb_pipeline.py
+- You need to create a Conda environment (or a virtual env) using `requirements.txt` in this directory
+- The script exercises three OBB endpoints, all of which require no credentials
+- Run the test from this directory:
+  cd examples/openbb-apachebeam
+  python -m unittest tests/test_obb_pipeline.py
 
-The script will run a pipeline consisting of 3 task which will fetch AAPL quote, profile and news
-This is just a very basic sample which can be used as building block to create more complex scenarios
+The script will run a pipeline consisting of three tasks which will fetch an AAPL quote, profile, and news.
+This is just a very basic sample which can be used as a building block to create more complex scenarios
diff --git a/examples/openbb-apachebeam/tests/test_obb_pipeline.py b/examples/openbb-apachebeam/tests/test_obb_pipeline.py
index 097df423703..69ab99e9095 100644
--- a/examples/openbb-apachebeam/tests/test_obb_pipeline.py
+++ b/examples/openbb-apachebeam/tests/test_obb_pipeline.py
@@ -22,26 +22,35 @@ class AsyncProcess(beam.DoFn):
     def process(self, element: str):
         return asyncio.run(self.fetch_data(element))
 
+
 class MyTestCase(unittest.TestCase):
 
-
     def test_sample_pipeline(self):
-        credentials = {} # Running OBB endpoints which do not require credentials
+        credentials = {}  # Running OBB endpoints which do not require credentials
         debug_sink = beam.Map(print)
         ticker = 'AAPL'
 
         with TestPipeline(options=PipelineOptions()) as p:
-            quote = (p | 'Start Quote' >> beam.Create([ticker])
-                     | 'Run Quote' >> beam.ParDo(AsyncProcess(credentials, quote_fetcher))
-                     | 'Print quote' >> debug_sink)
+            quote = (
+                p
+                | 'Start Quote' >> beam.Create([ticker])
+                | 'Run Quote' >> beam.ParDo(AsyncProcess(credentials, quote_fetcher))
+                | 'Print quote' >> debug_sink
+            )
 
-            profile = (p | 'Start Profile' >> beam.Create([ticker])
-                     | 'Run Profile' >> beam.ParDo(AsyncProcess(credentials, profile_fetcher))
-                     | 'Print profile' >> debug_sink)
+            profile = (
+                p
+                | 'Start Profile' >> beam.Create([ticker])
+                | 'Run Profile' >> beam.ParDo(AsyncProcess(credentials, profile_fetcher))
+                | 'Print profile' >> debug_sink
+            )
 
-            news = (p | 'Start News' >> beam.Create([ticker])
-                       | 'Run News' >> beam.ParDo(AsyncProcess(credentials, news_fetcher))
-                       | 'Print nes' >> debug_sink)
+            news = (
+                p
+                | 'Start News' >> beam.Create([ticker])
+                | 'Run News' >> beam.ParDo(AsyncProcess(credentials, news_fetcher))
+                | 'Print news' >> debug_sink
+            )
 
 
 if __name__ == '__main__':