Skip to content

Commit 57b151a

Browse files
shunpingshunping
authored
Some minor fixes after beam 2.65.0 was released. (#35057)
* Some minor fixes after beam 2.65.0 was released. * Fix extra package path.
1 parent e22fdc1 commit 57b151a

File tree

1 file changed

+26
-42
lines changed

1 file changed

+26
-42
lines changed

‎examples/notebooks/beam-ml/anomaly_detection/anomaly_detection_iforest.ipynb‎

Lines changed: 26 additions & 42 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
"colab": {
66
"provenance": [],
77
"toc_visible": true,
8-
"authorship_tag": "ABX9TyNi12IlrUN5hBIe3aoQazij"
8+
"authorship_tag": "ABX9TyN4D6iVLtKHQm9QRmuNNcC4"
99
},
1010
"kernelspec": {
1111
"name": "python3",
@@ -43,7 +43,7 @@
4343
"id": "IA9uYREbI3m3"
4444
},
4545
"execution_count": null,
46-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
46+
"outputs": []
4747
},
4848
{
4949
"cell_type": "markdown",
@@ -101,7 +101,7 @@
101101
"metadata": {
102102
"id": "L_18eUf7QU2I"
103103
},
104-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}],
104+
"outputs": [],
105105
"source": [
106106
"# GCP project id\n",
107107
"PROJECT_ID = 'apache-beam-testing' # @param {type:'string'}\n",
@@ -112,8 +112,7 @@
112112
"# Required if running on Dataflow\n",
113113
"REGION = 'us-central1' # @param {type:'string'}\n",
114114
"\n",
115-
"# TODO: Change this to an official release once 2.65.0 is available\n",
116-
"BEAM_VERSION = '2.65.0rc2'\n",
115+
"BEAM_VERSION = '2.65.0'\n",
117116
"\n",
118117
"import random\n",
119118
"SUFFIX = str(random.randint(0, 10000))"
@@ -129,7 +128,7 @@
129128
"id": "A_49Y2aTQeiH"
130129
},
131130
"execution_count": null,
132-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
131+
"outputs": []
133132
},
134133
{
135134
"cell_type": "markdown",
@@ -150,20 +149,7 @@
150149
"id": "5hpDAMOyQfHP"
151150
},
152151
"execution_count": null,
153-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
154-
},
155-
{
156-
"cell_type": "code",
157-
"source": [
158-
"# Download the latest prism\n",
159-
"# TODO: We don't need this step once 2.65.0 is available.\n",
160-
"! wget https://dist.apache.org/repos/dist/dev/beam/2.65.0/prism/linux/amd64/apache_beam-v2.65.0-prism-linux-amd64.zip"
161-
],
162-
"metadata": {
163-
"id": "jAKBvrgq-J3f"
164-
},
165-
"execution_count": null,
166-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
152+
"outputs": []
167153
},
168154
{
169155
"cell_type": "code",
@@ -175,7 +161,7 @@
175161
"id": "KlkX-iwVm42J"
176162
},
177163
"execution_count": null,
178-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
164+
"outputs": []
179165
},
180166
{
181167
"cell_type": "markdown",
@@ -206,7 +192,7 @@
206192
"id": "vb6ubiSyipuG"
207193
},
208194
"execution_count": null,
209-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
195+
"outputs": []
210196
},
211197
{
212198
"cell_type": "code",
@@ -236,7 +222,7 @@
236222
"id": "P9MzeokSiPxK"
237223
},
238224
"execution_count": null,
239-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
225+
"outputs": []
240226
},
241227
{
242228
"cell_type": "code",
@@ -251,7 +237,7 @@
251237
"id": "01JdmTuXuqY_"
252238
},
253239
"execution_count": null,
254-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
240+
"outputs": []
255241
},
256242
{
257243
"cell_type": "markdown",
@@ -366,7 +352,7 @@
366352
"id": "4WgxpmAPQrbv"
367353
},
368354
"execution_count": null,
369-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
355+
"outputs": []
370356
},
371357
{
372358
"cell_type": "markdown",
@@ -388,7 +374,7 @@
388374
"id": "fnidxXybxuFD"
389375
},
390376
"execution_count": null,
391-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
377+
"outputs": []
392378
},
393379
{
394380
"cell_type": "code",
@@ -415,7 +401,7 @@
415401
"id": "iwkrY8oXSAlQ"
416402
},
417403
"execution_count": null,
418-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
404+
"outputs": []
419405
},
420406
{
421407
"cell_type": "markdown",
@@ -438,7 +424,7 @@
438424
"id": "jP_M9pY2mp1C"
439425
},
440426
"execution_count": null,
441-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
427+
"outputs": []
442428
},
443429
{
444430
"cell_type": "code",
@@ -457,8 +443,7 @@
457443
" \"--streaming\",\n",
458444
" \"--job_server_timeout=600\",\n",
459445
" \"--environment_type=LOOPBACK\",\n",
460-
" # TODO: remove --prism_location once 2.65 is released\n",
461-
" \"--runner=PrismRunner\", \"--prism_location=./apache_beam-v2.65.0-prism-linux-amd64.zip\"\n",
446+
" \"--runner=PrismRunner\",\n",
462447
"])\n",
463448
"\n",
464449
"with beam.Pipeline(options=options) as p:\n",
@@ -476,7 +461,7 @@
476461
"id": "ghFoWPAeS6SH"
477462
},
478463
"execution_count": null,
479-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
464+
"outputs": []
480465
},
481466
{
482467
"cell_type": "markdown",
@@ -498,7 +483,7 @@
498483
"id": "Gh-bU6vsD9vD"
499484
},
500485
"execution_count": null,
501-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
486+
"outputs": []
502487
},
503488
{
504489
"cell_type": "code",
@@ -510,7 +495,7 @@
510495
"id": "0C0qur71DiN3"
511496
},
512497
"execution_count": null,
513-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
498+
"outputs": []
514499
},
515500
{
516501
"cell_type": "code",
@@ -522,7 +507,7 @@
522507
" \"--staging_location=\" + STAGING_LOCATION,\n",
523508
" \"--project=\" + PROJECT_ID,\n",
524509
" \"--region=\" + REGION,\n",
525-
" \"--extra_package=gs://shunping-test/anomaly-temp/pyod-2.0.3.tar.gz\",\n",
510+
" \"--extra_package=gs://apache-beam-samples/anomaly_detection/pyod/pyod-2.0.3.tar.gz\",\n",
526511
"])\n",
527512
"\n",
528513
"with beam.Pipeline(options=options) as p:\n",
@@ -540,7 +525,7 @@
540525
"id": "-uspd0osDocV"
541526
},
542527
"execution_count": null,
543-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
528+
"outputs": []
544529
},
545530
{
546531
"cell_type": "markdown",
@@ -572,7 +557,7 @@
572557
"id": "KkyuDIVoePnv"
573558
},
574559
"execution_count": null,
575-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
560+
"outputs": []
576561
},
577562
{
578563
"cell_type": "code",
@@ -591,7 +576,7 @@
591576
"id": "x_lEnelMj1fD"
592577
},
593578
"execution_count": null,
594-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
579+
"outputs": []
595580
},
596581
{
597582
"cell_type": "code",
@@ -604,7 +589,7 @@
604589
"id": "N5w0K5B1jnIm"
605590
},
606591
"execution_count": null,
607-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
592+
"outputs": []
608593
},
609594
{
610595
"cell_type": "markdown",
@@ -626,8 +611,7 @@
626611
" \"--streaming\",\n",
627612
" \"--job_server_timeout=600\",\n",
628613
" \"--environment_type=LOOPBACK\",\n",
629-
" # TODO: remove --prism_location once 2.65 is released\n",
630-
" \"--runner=PrismRunner\", \"--prism_location=./apache_beam-v2.65.0-prism-linux-amd64.zip\"\n",
614+
" \"--runner=PrismRunner\",\n",
631615
"])\n",
632616
"\n",
633617
"with beam.Pipeline(options=options) as p:\n",
@@ -644,7 +628,7 @@
644628
"id": "gWRplG09kXmh"
645629
},
646630
"execution_count": null,
647-
"outputs": [{"output_type": "stream", "name": "stdout", "text": ["\n"]}]
631+
"outputs": []
648632
}
649633
]
650-
}
634+
}

0 commit comments

Comments
 (0)