diff --git a/pipelinewise/fastsync/partialsync/postgres_to_snowflake.py b/pipelinewise/fastsync/partialsync/postgres_to_snowflake.py index 7d18eb82d..95e0afef7 100644 --- a/pipelinewise/fastsync/partialsync/postgres_to_snowflake.py +++ b/pipelinewise/fastsync/partialsync/postgres_to_snowflake.py @@ -135,7 +135,7 @@ def main_impl(): sync_tables = utils.get_sync_tables(args) - pool_size = len(sync_tables) if len(sync_tables)< pool_size else pool_size + pool_size = len(sync_tables) if len(sync_tables) < pool_size else pool_size with multiprocessing.Pool(pool_size) as proc: sync_excs = list( filter( @@ -144,8 +144,6 @@ def main_impl(): ) ) - - if isinstance(sync_excs, bool): sync_excs = None