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:35 UTC
[beam] branch damccorm-patch-1 created (now fa3fe510eda)
This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a change to branch damccorm-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git
at fa3fe510eda Fix syntax issues with notebook
This branch includes the following new commits:
new fa3fe510eda Fix syntax issues with notebook
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[beam] 01/01: Fix syntax issues with notebook
Posted by da...@apache.org.
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": {