You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2023/04/26 16:47:36 UTC
[beam] 01/01: Fix syntax issues with notebook
This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch damccorm-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git
commit fa3fe510eda4a4e8bb230e145d818bf0b3a09744
Author: Danny McCormick <da...@google.com>
AuthorDate: Wed Apr 26 12:47:29 2023 -0400
Fix syntax issues with notebook
---
examples/notebooks/beam-ml/automatic_model_refresh.ipynb | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/examples/notebooks/beam-ml/automatic_model_refresh.ipynb b/examples/notebooks/beam-ml/automatic_model_refresh.ipynb
index 408d39f5786..486b11679d9 100644
--- a/examples/notebooks/beam-ml/automatic_model_refresh.ipynb
+++ b/examples/notebooks/beam-ml/automatic_model_refresh.ipynb
@@ -410,7 +410,7 @@
" | \"MainInputPcoll\" >> PeriodicImpulse(\n",
" start_timestamp=start_timestamp,\n",
" stop_timestamp=end_timestamp,\n",
- " fire_interval=main_input_fire_interval)"
+ " fire_interval=main_input_fire_interval))"
],
"metadata": {
"id": "vUFStz66_Tbb",
@@ -489,16 +489,16 @@
"cell_type": "code",
"source": [
" # The side input used to watch for the .h5 file and update the model_uri of the TFModelHandlerTensor.\n",
- " file_pattern = 'gs://BUCKET_NAME/*.h5'\n",
- " side_input_pcoll = (\n",
+ "file_pattern = 'gs://BUCKET_NAME/*.h5'\n",
+ "side_input_pcoll = (\n",
" pipeline\n",
" | \"WatchFilePattern\" >> WatchFilePattern(file_pattern=file_pattern,\n",
" interval=side_input_fire_interval,\n",
" stop_timestamp=end_timestamp))\n",
- " inferences = (\n",
- " image_data\n",
- " | \"ApplyWindowing\" >> beam.WindowInto(beam.window.FixedWindows(10))\n",
- " | \"RunInference\" >> RunInference(model_handler=model_handler,\n",
+ "inferences = (\n",
+ " image_data\n",
+ " | \"ApplyWindowing\" >> beam.WindowInto(beam.window.FixedWindows(10))\n",
+ " | \"RunInference\" >> RunInference(model_handler=model_handler,\n",
" model_metadata_pcoll=side_input_pcoll))"
],
"metadata": {