diff --git a/notebooks/scenarios/bigquery/020-configure-api.ipynb b/notebooks/scenarios/bigquery/020-configure-api.ipynb index 1371dfaf5c7..7e5ddcde2e6 100644 --- a/notebooks/scenarios/bigquery/020-configure-api.ipynb +++ b/notebooks/scenarios/bigquery/020-configure-api.ipynb @@ -185,7 +185,7 @@ " description=\"This endpoint allows to query Bigquery storage via SQL queries.\",\n", " private_function=private_func,\n", " mock_function=mock_func,\n", - " worker_pool=this_worker_pool_name,\n", + " worker_pool_name=this_worker_pool_name,\n", ")\n", "\n", "high_client.custom_api.add(endpoint=new_endpoint)" @@ -376,7 +376,7 @@ " settings={\n", " \"calls_per_min\": 5,\n", " },\n", - " worker_pool=this_worker_pool_name,\n", + " worker_pool_name=this_worker_pool_name,\n", ")" ] }, @@ -431,7 +431,7 @@ "outputs": [], "source": [ "submit_query_function = make_submit_query(\n", - " settings={}, worker_pool=this_worker_pool_name\n", + " settings={}, worker_pool_name=this_worker_pool_name\n", ")" ] }, diff --git a/notebooks/scenarios/bigquery/sync/020-configure-api-and-sync.ipynb b/notebooks/scenarios/bigquery/sync/020-configure-api-and-sync.ipynb index 2f9658634e3..57ce09343d1 100644 --- a/notebooks/scenarios/bigquery/sync/020-configure-api-and-sync.ipynb +++ b/notebooks/scenarios/bigquery/sync/020-configure-api-and-sync.ipynb @@ -166,7 +166,7 @@ " settings={\n", " \"calls_per_min\": 5,\n", " },\n", - " worker_pool=this_worker_pool_name,\n", + " worker_pool_name=this_worker_pool_name,\n", ")" ] }, @@ -270,7 +270,7 @@ " description=\"This endpoint allows to query Bigquery storage via SQL queries.\",\n", " private_function=private_func,\n", " mock_function=mock_func,\n", - " worker_pool=this_worker_pool_name,\n", + " worker_pool_name=this_worker_pool_name,\n", ")\n", "\n", "high_client.custom_api.add(endpoint=new_endpoint)" @@ -393,7 +393,7 @@ "outputs": [], "source": [ "submit_query_function = make_submit_query(\n", - " settings={}, worker_pool=this_worker_pool_name\n", + " settings={}, worker_pool_name=this_worker_pool_name\n", ")" ] }, @@ -614,7 +614,7 @@ "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython3", - "version": "3.12.4" + "version": "3.12.5" } }, "nbformat": 4, diff --git a/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/live/schema.py b/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/live/schema.py index 03012c7d0cf..d1ff1cf9b05 100644 --- a/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/live/schema.py +++ b/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/live/schema.py @@ -7,7 +7,7 @@ from syft.rate_limiter import is_within_rate_limit -def make_schema(settings: dict, worker_pool: str) -> Callable: +def make_schema(settings: dict, worker_pool_name: str) -> Callable: updated_settings = { "calls_per_min": 5, "rate_limiter_enabled": True, @@ -26,7 +26,7 @@ def make_schema(settings: dict, worker_pool: str) -> Callable: helper_functions=[ is_within_rate_limit ], # Adds ratelimit as this is also a method available to data scientists - worker_pool=worker_pool, + worker_pool_name=worker_pool_name, ) def live_schema( context, diff --git a/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/mock/schema.py b/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/mock/schema.py index a95e04f2f1d..0780cf7b8e8 100644 --- a/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/mock/schema.py +++ b/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/mock/schema.py @@ -9,7 +9,7 @@ from .data import schema_dict -def make_schema(settings, worker_pool) -> Callable: +def make_schema(settings, worker_pool_name) -> Callable: updated_settings = { "calls_per_min": 5, "rate_limiter_enabled": True, @@ -21,7 +21,7 @@ def make_schema(settings, worker_pool) -> Callable: description="This endpoint allows for visualising the metadata of tables available in BigQuery.", settings=updated_settings, helper_functions=[is_within_rate_limit], - worker_pool=worker_pool, + worker_pool_name=worker_pool_name, ) def mock_schema( context, diff --git a/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/submit_query.py b/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/submit_query.py index a0125ee009b..d58d030f834 100644 --- a/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/submit_query.py +++ b/notebooks/scenarios/bigquery/upgradability/0.9.1_helpers/apis/submit_query.py @@ -2,13 +2,13 @@ import syft as sy -def make_submit_query(settings, worker_pool): - updated_settings = {"user_code_worker": worker_pool} | settings +def make_submit_query(settings, worker_pool_name): + updated_settings = {"user_code_worker": worker_pool_name} | settings @sy.api_endpoint( path="bigquery.submit_query", description="API endpoint that allows you to submit SQL queries to run on the private data.", - worker_pool=worker_pool, + worker_pool_name=worker_pool_name, settings=updated_settings, ) def submit_query( diff --git a/notebooks/scenarios/bigquery/upgradability/0.9.1_notebooks/020-configure-api.ipynb b/notebooks/scenarios/bigquery/upgradability/0.9.1_notebooks/020-configure-api.ipynb index 4a7954cf5e7..3a2de9b445c 100644 --- a/notebooks/scenarios/bigquery/upgradability/0.9.1_notebooks/020-configure-api.ipynb +++ b/notebooks/scenarios/bigquery/upgradability/0.9.1_notebooks/020-configure-api.ipynb @@ -216,7 +216,7 @@ " description=\"This endpoint allows to query Bigquery storage via SQL queries.\",\n", " private_function=private_func,\n", " mock_function=mock_func,\n", - " worker_pool=this_worker_pool_name,\n", + " worker_pool_name=this_worker_pool_name,\n", ")\n", "\n", "high_client.custom_api.add(endpoint=new_endpoint)" @@ -407,7 +407,7 @@ " settings={\n", " \"calls_per_min\": 5,\n", " },\n", - " worker_pool=this_worker_pool_name,\n", + " worker_pool_name=this_worker_pool_name,\n", ")" ] }, @@ -462,7 +462,7 @@ "outputs": [], "source": [ "submit_query_function = make_submit_query(\n", - " settings={}, worker_pool=this_worker_pool_name\n", + " settings={}, worker_pool_name=this_worker_pool_name\n", ")" ] }, diff --git a/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/02-configure-api-and-sync.ipynb b/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/02-configure-api-and-sync.ipynb index ad7bf7a823a..243d259cb6d 100644 --- a/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/02-configure-api-and-sync.ipynb +++ b/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/02-configure-api-and-sync.ipynb @@ -176,7 +176,7 @@ " description=\"This endpoint allows to query Bigquery storage via SQL queries.\",\n", " private_function=private_func,\n", " mock_function=mock_func,\n", - " worker_pool=this_worker_pool_name,\n", + " worker_pool_name=this_worker_pool_name,\n", ")\n", "\n", "high_client.custom_api.add(endpoint=new_endpoint)" @@ -221,7 +221,7 @@ " settings={\n", " \"calls_per_min\": 5,\n", " },\n", - " worker_pool=this_worker_pool_name,\n", + " worker_pool_name=this_worker_pool_name,\n", ")" ] }, @@ -282,7 +282,7 @@ "outputs": [], "source": [ "submit_query_function = make_submit_query(\n", - " settings={}, worker_pool=this_worker_pool_name\n", + " settings={}, worker_pool_name=this_worker_pool_name\n", ")" ] }, diff --git a/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/live/schema.py b/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/live/schema.py index 5b39d9d9066..9ef82352e02 100644 --- a/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/live/schema.py +++ b/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/live/schema.py @@ -9,7 +9,7 @@ from ..rate_limiter import is_within_rate_limit -def make_schema(settings: dict, worker_pool: str) -> Callable: +def make_schema(settings: dict, worker_pool_name: str) -> Callable: updated_settings = { "calls_per_min": 5, "rate_limiter_enabled": True, @@ -28,7 +28,7 @@ def make_schema(settings: dict, worker_pool: str) -> Callable: helper_functions=[ is_within_rate_limit ], # Adds ratelimit as this is also a method available to data scientists - worker_pool=worker_pool, + worker_pool_name=worker_pool_name, ) def live_schema( context, diff --git a/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/mock/schema.py b/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/mock/schema.py index a95e04f2f1d..0780cf7b8e8 100644 --- a/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/mock/schema.py +++ b/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/mock/schema.py @@ -9,7 +9,7 @@ from .data import schema_dict -def make_schema(settings, worker_pool) -> Callable: +def make_schema(settings, worker_pool_name) -> Callable: updated_settings = { "calls_per_min": 5, "rate_limiter_enabled": True, @@ -21,7 +21,7 @@ def make_schema(settings, worker_pool) -> Callable: description="This endpoint allows for visualising the metadata of tables available in BigQuery.", settings=updated_settings, helper_functions=[is_within_rate_limit], - worker_pool=worker_pool, + worker_pool_name=worker_pool_name, ) def mock_schema( context, diff --git a/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/submit_query.py b/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/submit_query.py index a0125ee009b..d58d030f834 100644 --- a/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/submit_query.py +++ b/notebooks/scenarios/bigquery/upgradability/sync/0.9.1_notebooks/apis/submit_query.py @@ -2,13 +2,13 @@ import syft as sy -def make_submit_query(settings, worker_pool): - updated_settings = {"user_code_worker": worker_pool} | settings +def make_submit_query(settings, worker_pool_name): + updated_settings = {"user_code_worker": worker_pool_name} | settings @sy.api_endpoint( path="bigquery.submit_query", description="API endpoint that allows you to submit SQL queries to run on the private data.", - worker_pool=worker_pool, + worker_pool_name=worker_pool_name, settings=updated_settings, ) def submit_query(