|
6 | 6 | from unittest import TestCase, skipIf
|
7 | 7 |
|
8 | 8 | from requests import Request
|
9 |
| -from tests.utils.testutils_lc import LinuxConsumptionWebHostController |
10 | 9 |
|
11 | 10 | from azure_functions_worker.constants import (
|
12 | 11 | PYTHON_ENABLE_DEBUG_LOGGING,
|
13 | 12 | PYTHON_ENABLE_INIT_INDEXING,
|
14 | 13 | PYTHON_ENABLE_WORKER_EXTENSIONS,
|
15 | 14 | PYTHON_ISOLATE_WORKER_DEPENDENCIES,
|
16 | 15 | )
|
| 16 | +from tests.utils.testutils_lc import LinuxConsumptionWebHostController |
17 | 17 |
|
18 | 18 | _DEFAULT_HOST_VERSION = "4"
|
19 | 19 |
|
@@ -61,6 +61,7 @@ def test_http_no_auth(self):
|
61 | 61 | "AzureWebJobsStorage": self._storage,
|
62 | 62 | "SCM_RUN_FROM_PACKAGE": self._get_blob_url("HttpNoAuth")
|
63 | 63 | })
|
| 64 | + |
64 | 65 | req = Request('GET', f'{ctrl.url}/api/HttpTrigger')
|
65 | 66 | resp = ctrl.send_request(req)
|
66 | 67 | self.assertEqual(resp.status_code, 200)
|
@@ -377,7 +378,8 @@ def generate_random_bytes_stream():
|
377 | 378 | streamed_data, b'streamingtestingresponseisreturned')
|
378 | 379 |
|
379 | 380 | def _get_blob_url(self, scenario_name: str) -> str:
|
| 381 | + sas_token = os.getenv(f"SAS_TOKEN{self._py_shortform}") |
380 | 382 | return (
|
381 | 383 | f'https://pythonworker{self._py_shortform}sa.blob.core.windows.net/'
|
382 |
| - f'python-worker-lc-apps/{scenario_name}{self._py_shortform}.zip' |
| 384 | + f'python-worker-lc-apps/{scenario_name}{self._py_shortform}.zip?{sas_token}' |
383 | 385 | )
|
0 commit comments