run all non large data blob tests for v2 / generic 313

Author: hallvictoria

workers/tests/emulator_tests/test_blob_functions.py

@@ -42,19 +42,19 @@ def test_blob_io_str(self):
     #     self.assertEqual(r.status_code, 200)
     #     self.assertEqual(r.text, large_string)
 
-    # def test_blob_io_bytes(self):
-    #     r = self.webhost.request('POST', 'put_blob_bytes',
-    #                              data='test-dată'.encode('utf-8'))
-    #     self.assertEqual(r.status_code, 200)
-    #     self.assertEqual(r.text, 'OK')
+    def test_blob_io_bytes(self):
+        r = self.webhost.request('POST', 'put_blob_bytes',
+                                 data='test-dată'.encode('utf-8'))
+        self.assertEqual(r.status_code, 200)
+        self.assertEqual(r.text, 'OK')
 
-    #     r = self.webhost.request('POST', 'get_blob_bytes')
-    #     self.assertEqual(r.status_code, 200)
-    #     self.assertEqual(r.text, 'test-dată')
+        r = self.webhost.request('POST', 'get_blob_bytes')
+        self.assertEqual(r.status_code, 200)
+        self.assertEqual(r.text, 'test-dată')
 
-    #     r = self.webhost.request('POST', 'get_blob_as_bytes')
-    #     self.assertEqual(r.status_code, 200)
-    #     self.assertEqual(r.text, 'test-dată')
+        r = self.webhost.request('POST', 'get_blob_as_bytes')
+        self.assertEqual(r.status_code, 200)
+        self.assertEqual(r.text, 'test-dată')
 
     # def test_blob_io_large_bytes(self):
     #     large_string = 'DummyDataDummyDataDummyData' * 1024 * 1024  # 27 MB
@@ -72,52 +72,52 @@ def test_blob_io_str(self):
     #     self.assertEqual(r.status_code, 200)
     #     self.assertEqual(r.text, large_string)
 
-    # def test_blob_io_filelike(self):
-    #     r = self.webhost.request('POST', 'put_blob_filelike')
-    #     self.assertEqual(r.status_code, 200)
-    #     self.assertEqual(r.text, 'OK')
+    def test_blob_io_filelike(self):
+        r = self.webhost.request('POST', 'put_blob_filelike')
+        self.assertEqual(r.status_code, 200)
+        self.assertEqual(r.text, 'OK')
 
-    #     r = self.webhost.request('POST', 'get_blob_filelike')
-    #     self.assertEqual(r.status_code, 200)
-    #     self.assertEqual(r.text, 'filelike')
+        r = self.webhost.request('POST', 'get_blob_filelike')
+        self.assertEqual(r.status_code, 200)
+        self.assertEqual(r.text, 'filelike')
 
-    # def test_blob_io_return(self):
-    #     r = self.webhost.request('POST', 'put_blob_return')
-    #     self.assertEqual(r.status_code, 200)
+    def test_blob_io_return(self):
+        r = self.webhost.request('POST', 'put_blob_return')
+        self.assertEqual(r.status_code, 200)
 
-    #     r = self.webhost.request('POST', 'get_blob_return')
-    #     self.assertEqual(r.status_code, 200)
-    #     self.assertEqual(r.text, 'FROM RETURN')
+        r = self.webhost.request('POST', 'get_blob_return')
+        self.assertEqual(r.status_code, 200)
+        self.assertEqual(r.text, 'FROM RETURN')
 
-    # def test_blob_trigger(self):
-    #     data = "DummyData"
+    def test_blob_trigger(self):
+        data = "DummyData"
 
-    #     r = self.webhost.request('POST', 'put_blob_trigger',
-    #                              data=data.encode('utf-8'))
-    #     self.assertEqual(r.status_code, 200)
-    #     self.assertEqual(r.text, 'OK')
+        r = self.webhost.request('POST', 'put_blob_trigger',
+                                 data=data.encode('utf-8'))
+        self.assertEqual(r.status_code, 200)
+        self.assertEqual(r.text, 'OK')
 
-    #     # Blob trigger may be processed after some delay
-    #     # We check it every 2 seconds to allow the trigger to be fired
-    #     max_retries = 10
-    #     for try_no in range(max_retries):
-    #         time.sleep(2)
+        # Blob trigger may be processed after some delay
+        # We check it every 2 seconds to allow the trigger to be fired
+        max_retries = 10
+        for try_no in range(max_retries):
+            time.sleep(2)
 
-    #         try:
-    #             # Check that the trigger has fired
-    #             r = self.webhost.request('GET', 'get_blob_triggered')
-    #             self.assertEqual(r.status_code, 200)
-    #             response = r.json()
+            try:
+                # Check that the trigger has fired
+                r = self.webhost.request('GET', 'get_blob_triggered')
+                self.assertEqual(r.status_code, 200)
+                response = r.json()
 
-    #             self.assertEqual(response['name'],
-    #                              'python-worker-tests/test-blob-trigger.txt')
-    #             self.assertEqual(response['content'], data)
+                self.assertEqual(response['name'],
+                                 'python-worker-tests/test-blob-trigger.txt')
+                self.assertEqual(response['content'], data)
 
-    #             break
-    #         # JSONDecodeError will be thrown if the response is empty.
-    #         except (AssertionError, JSONDecodeError):
-    #             if try_no == max_retries - 1:
-    #                 raise
+                break
+            # JSONDecodeError will be thrown if the response is empty.
+            except (AssertionError, JSONDecodeError):
+                if try_no == max_retries - 1:
+                    raise
 
     # def test_blob_trigger_with_large_content(self):
     #     data = 'DummyDataDummyDataDummyData' * 1024 * 1024  # 27 MB
@@ -159,8 +159,6 @@ def get_script_dir(cls):
             'blob_functions_stein'
 
 
-@skipIf(sys.version_info.minor >= 13,
-        'Temporary skip for Python 3.13+')
 class TestBlobFunctionsSteinGeneric(TestBlobFunctions):
 
     @classmethod