Update start.py

Engineering-Research-and-Development · Jul 18, 2023 · 374ab39 · 374ab39
1 parent 5ed78fd
commit 374ab39
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/ci/v2_test/start.py b/ci/v2_test/start.py
@@ -16,9 +16,9 @@
 event, ssc = connector.Prime(sc, 5 , StorageLevel.MEMORY_AND_DISK_2)
 
 event = event.flatMap(lambda x: x.entities).map(lambda x: x.attrs['price'].value)
-response = event.map(lambda x : connector.UnstructuredReplyToBroker('{ "value" :' + str(20) +' }', "http://localhost:1026/v2/entities/urn:ngsi-ld:Product:010/attrs/price/", "PATCH"))
-response2 = event.map(lambda x: connector.SemistructuredReplyToBroker(20, '{"value" : %%TOREPLACE%% }',  "http://localhost:1026/v2/entities/urn:ngsi-ld:Product:010/attrs/price/", "PATCH"))
-response3 = event.map(lambda x : connector.ReplyToBroker(20,  "http://localhost:1026/v2/entities/urn:ngsi-ld:Product:010/attrs/price/", "PATCH"))
+response3 = event.map(lambda x : connector.ReplyToBroker(20,  "http://localhost:1026/v2/entities/urn:ngsi-ld:Product:010/attrs/price/", "PUT"))
+response = event.map(lambda x : connector.UnstructuredReplyToBroker('{ "value" :' + str(20) +' }', "http://localhost:1026/v2/entities/urn:ngsi-ld:Product:010/attrs/price/", "PUT"))
+response2 = event.map(lambda x: connector.SemistructuredReplyToBroker(20, '{"value" : %%TOREPLACE%% }',  "http://localhost:1026/v2/entities/urn:ngsi-ld:Product:010/attrs/price/", "PUT"))
 event.pprint()
 response.pprint()
 response2.pprint()