formatting

eva/optimizer/plan_generator.py

@@ -115,7 +115,9 @@ def _recursive_strip_exchange(plan: AbstractPlan, is_top: bool = False):
                     plan.append_child(child)
 
                 if isinstance(plan, ExchangePlan):
-                    assert not is_top or len(plan.children) == 1, "Top ExchangePlan can only have 1 child."
+                    assert (
+                        not is_top or len(plan.children) == 1
+                    ), "Top ExchangePlan can only have 1 child."
                     return plan.children
                 else:
                     return [plan]

test/integration_tests/test_like.py

@@ -13,11 +13,11 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 import unittest
+from test.util import shutdown_ray
 
 from eva.catalog.catalog_manager import CatalogManager
 from eva.configuration.constants import EVA_ROOT_DIR
 from eva.server.command_handler import execute_query_fetch_all
-from test.util import shutdown_ray
 
 
 class LikeTest(unittest.TestCase):

test/optimizer/test_cascade_optimizer.py

@@ -19,13 +19,13 @@
 import pytest
 
 from eva.catalog.catalog_manager import CatalogManager
+from eva.experimental.ray.planner.exchange_plan import ExchangePlan
 from eva.models.storage.batch import Batch
-from eva.server.command_handler import execute_query_fetch_all
-from eva.plan_nodes.project_plan import ProjectPlan
+from eva.optimizer.plan_generator import PlanGenerator
 from eva.plan_nodes.nested_loop_join_plan import NestedLoopJoinPlan
+from eva.plan_nodes.project_plan import ProjectPlan
 from eva.plan_nodes.storage_plan import StoragePlan
-from eva.experimental.ray.planner.exchange_plan import ExchangePlan
-from eva.optimizer.plan_generator import PlanGenerator
+from eva.server.command_handler import execute_query_fetch_all
 
 
 @pytest.mark.notparallel