From 3224520a89f64d61489d520dbf0cc27c93c98052 Mon Sep 17 00:00:00 2001 From: Bastien Gautier Date: Fri, 1 Mar 2024 16:54:27 +0000 Subject: [PATCH] Change process numbers --- src/snow_revoke_privileges/snow_privileges.py | 2 +- src/snow_revoke_privileges/tools/my_snowflake.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/snow_revoke_privileges/snow_privileges.py b/src/snow_revoke_privileges/snow_privileges.py index 83dbdc9..1e222f6 100644 --- a/src/snow_revoke_privileges/snow_privileges.py +++ b/src/snow_revoke_privileges/snow_privileges.py @@ -97,7 +97,7 @@ def prepare_future_true(self) -> None: self.progress = Bar("Processing", max=len(only_database_schema)) - with Pool(processes=16) as pool: + with Pool(processes=8) as pool: for _ in pool.imap_unordered(self.prepare_future_true_task, only_database_schema.iterrows()): # pyright: ignore self.progress.next() diff --git a/src/snow_revoke_privileges/tools/my_snowflake.py b/src/snow_revoke_privileges/tools/my_snowflake.py index 3e60eb5..0effdcd 100644 --- a/src/snow_revoke_privileges/tools/my_snowflake.py +++ b/src/snow_revoke_privileges/tools/my_snowflake.py @@ -98,7 +98,7 @@ def execute_multi_requests(requests: List[str]) -> None: # pylint: disable=unus with Bar("Executing request in Snwoflake", max=len(requests)) as progress: - with Pool(processes=4) as pool: + with Pool(processes=8) as pool: for _ in pool.imap_unordered(MySnowflake.execute_single_request, requests): # pyright: ignore progress.next()