more 3.0 cleanup (#526)

docs/advanced/topics.md

@@ -43,7 +43,7 @@ sdf = app.dataframe(input_topic).to_topic(output_topic)
 
 # Run the Application. 
 # The topics will be validated and created during this function call.
-app.run(sdf)
+app.run()
 ```
 
 ## Topic Configuration
@@ -83,5 +83,5 @@ sdf = app.dataframe(input_topic).to_topic(output_topic)
 # Run the Application. 
 # The topics will be validated and created during this function call.
 # Note: if the topics already exist, the configs will remain intact.
-app.run(sdf)
+app.run()
 ```

docs/connectors/sources/README.md

@@ -15,7 +15,7 @@ def main():
   sdf = app.dataframe(source=source)
   sdf.print(metadata=True)
 
-  app.run(sdf)
+  app.run()
 
 if __name__ == "__main__":
   main()
@@ -60,7 +60,7 @@ def main():
   sdf = app.dataframe(topic=topic, source=source)
   sdf.print(metadata=True)
 
-  app.run(sdf)
+  app.run()
 
 if __name__ == "__main__":
   main()

docs/connectors/sources/csv-source.md

@@ -19,7 +19,7 @@ def main():
   sdf = app.dataframe(source=source)
   sdf.print(metadata=True)
 
-  app.run(sdf)
+  app.run()
 
 if __name__ == "__main__":
   main()

docs/connectors/sources/custom-sources.md

@@ -79,7 +79,7 @@ def main():
   sdf = app.dataframe(source=source)
   sdf.print(metadata=True)
 
-  app.run(sdf)
+  app.run()
 
 if __name__ == "__main__":
   main()
@@ -141,7 +141,7 @@ def main():
   sdf = app.dataframe(source=source)
   sdf.print(metadata=True)
 
-  app.run(sdf)
+  app.run()
 
 if __name__ == "__main__":
   main()

docs/connectors/sources/kafka-source.md

@@ -24,7 +24,7 @@ def main():
   sdf = app.dataframe(source=source)
   sdf.print(metadata=True)
 
-  app.run(sdf)
+  app.run()
 
 if __name__ == "__main__":
   main()

docs/connectors/sources/quix-source.md

@@ -23,7 +23,7 @@ def main():
   sdf = app.dataframe(source=source)
   sdf.print(metadata=True)
 
-  app.run(sdf)
+  app.run()
 
 if __name__ == "__main__":
   main()

docs/processing.md

@@ -95,7 +95,7 @@ sdf = (
 sdf = sdf.to_topic(output_topic)
 
 # Run the pipeline
-app.run(sdf)
+app.run()
 ```
 
 ### Data Types
@@ -480,7 +480,7 @@ sdf['average_is_null'] = sdf["average"].isnull()
 Under the good, when you access a column on `StreamingDataFrame` it generates the new `StreamingSeries` instance that refers to the value of the passed key.
 
 These objects are also lazy, and they are evaluated only when the `StreamingDataFrame`is
-executed by `app.run(sdf)`.
+executed by `app.run()`.
 
 When you set them back to the StreamingDataFrame or use them to filter data, it creates
 a new step in the pipeline to be evaluated later.

docs/quickstart.md

@@ -102,7 +102,7 @@ sdf = sdf.update(lambda row: print(f"Output: {row}"))
 
 # Run the streaming application
 if __name__ == "__main__":
-    app.run(sdf)
+    app.run()
 ```
 
 ### Step 4. Running the Producer

docs/tutorials/anomaly-detection/application.py

@@ -28,4 +28,4 @@ def should_alert(window_value: int, key, timestamp, headers):
 
 
 if __name__ == "__main__":
-    app.run(sdf)
+    app.run()

docs/tutorials/purchase-filtering/application.py

@@ -32,4 +32,4 @@ def get_purchase_totals(items):
 
 
 if __name__ == "__main__":
-    app.run(sdf)
+    app.run()

docs/tutorials/word-count/application.py

@@ -28,4 +28,4 @@ def should_skip(word_count_pair):
 
 
 if __name__ == "__main__":
-    app.run(sdf)
+    app.run()

examples/bank_example/json_version/consumer.py

@@ -66,4 +66,4 @@ def count_transactions(value: dict, state: State):
 
 if __name__ == "__main__":
     # Start message processing
-    app.run(sdf)
+    app.run()

examples/bank_example/quix_platform_version/consumer.py

@@ -69,4 +69,4 @@ def count_transactions(value: dict, state: State):
 
 if __name__ == "__main__":
     # Start message processing
-    app.run(sdf)
+    app.run()

examples/custom_websocket_source/main.py

@@ -108,7 +108,7 @@ def main():
     sdf.print()
 
     # Start the application
-    app.run(sdf)
+    app.run()
 
 
 if __name__ == "__main__":

quixstreams/app.py

@@ -94,7 +94,7 @@ class Application:
     df = app.dataframe(topic)
     df.apply(lambda value, context: print('New message', value))
 
-    app.run(dataframe=df)
+    app.run()
     ```
     """
 
@@ -477,7 +477,7 @@ def dataframe(
         df = app.dataframe(topic)
         df.apply(lambda value, context: print('New message', value)
 
-        app.run(dataframe=df)
+        app.run()
         ```
 
 

quixstreams/sources/base.py

@@ -56,7 +56,7 @@ def main():
         sdf = app.dataframe(source=source)
         sdf.print(metadata=True)
 
-        app.run(sdf)
+        app.run()
 
     if __name__ == "__main__":
         main()

quixstreams/sources/kafka/kafka.py

@@ -48,7 +48,7 @@ class KafkaReplicatorSource(Source):
 
     sdf = app.dataframe(source=source)
     sdf = sdf.print()
-    app.run(sdf)
+    app.run()
     ```
     """
 

quixstreams/sources/kafka/quix.py

@@ -42,7 +42,7 @@ class QuixEnvironmentSource(KafkaReplicatorSource):
 
     sdf = app.dataframe(source=source)
     sdf = sdf.print()
-    app.run(sdf)
+    app.run()
     ```
     """