Remove imports from Input module to prevent circular dependency

acto/checker/checker_set.py

@@ -7,7 +7,7 @@
 from acto.checker.impl.health import HealthChecker
 from acto.checker.impl.operator_log import OperatorLogChecker
 from acto.common import flatten_dict
-from acto.input import InputModel
+from acto.input.input import InputModel
 from acto.oracle_handle import OracleHandle
 from acto.result import OracleResults
 from acto.snapshot import Snapshot

acto/checker/impl/consistency.py

@@ -19,8 +19,8 @@
     invalid_input_message,
     is_subfield,
 )
-from acto.input import InputModel
 from acto.input.get_matched_schemas import find_matched_schema
+from acto.input.input import InputModel
 from acto.input.property_attribute import PropertyAttribute
 from acto.k8s_util.k8sutil import canonicalize_quantity
 from acto.result import ConsistencyOracleResult, InvalidInputResult

acto/checker/impl/tests/test_state.py

@@ -11,7 +11,7 @@
 from acto.checker.impl.consistency import ConsistencyChecker
 from acto.checker.impl.tests import load_snapshot
 from acto.common import Diff, PropertyPath
-from acto.input import DeterministicInputModel
+from acto.input.input import DeterministicInputModel
 from acto.result import (
     ConsistencyOracleResult,
     InvalidInputResult,

acto/engine.py

@@ -21,8 +21,7 @@
 from acto.common import kubernetes_client, print_event
 from acto.constant import CONST
 from acto.deploy import Deploy
-from acto.input import InputModel
-from acto.input.input import DeterministicInputModel
+from acto.input.input import DeterministicInputModel, InputModel
 from acto.input.testcase import TestCase
 from acto.input.testplan import TestGroup
 from acto.input.value_with_schema import ValueWithSchema, attach_schema_to_value

acto/input/__init__.py

@@ -1,2 +0,0 @@
-from .input import DeterministicInputModel, InputModel
-from .testcase import TestCase

acto/reproduce.py

@@ -13,8 +13,8 @@
 
 from acto import DEFAULT_KUBERNETES_VERSION
 from acto.engine import Acto
-from acto.input import TestCase
 from acto.input.input import DeterministicInputModel
+from acto.input.testcase import TestCase
 from acto.input.testplan import TestGroup
 from acto.input.value_with_schema import ValueWithSchema
 from acto.input.valuegenerator import extract_schema_with_value_generator

acto/schema/object.py

@@ -31,12 +31,8 @@ def __init__(self, path: list, schema: dict) -> None:
         self.properties: dict[str, BaseSchema] = {}
         self.additional_properties = None
         self.required = []
-        logger = get_thread_logger(with_prefix=True)
         if "properties" not in schema and "additionalProperties" not in schema:
-            logger.warning(
-                "Object schema %s does not have properties nor additionalProperties",
-                self.path,
-            )
+            return
         if "properties" in schema:
             for property_key, property_schema in schema["properties"].items():
                 self.properties[property_key] = extract_schema(

acto/serialization.py

@@ -9,7 +9,7 @@
 from deepdiff.helper import NotPresent
 
 from acto.common import Diff, PropertyPath
-from acto.input import TestCase
+from acto.input.testcase import TestCase
 
 
 def _serialize_decimal(value: decimal.Decimal):

test/integration_tests/test_cassop_bugs.py

@@ -1,4 +1,5 @@
 """Integration tests for cass-operator bugs."""
+
 import json
 import os
 import pathlib
@@ -8,7 +9,7 @@
 
 from acto import acto_config
 from acto.checker.checker_set import CheckerSet
-from acto.input import DeterministicInputModel, InputModel
+from acto.input.input import DeterministicInputModel, InputModel
 from acto.lib.operator_config import OperatorConfig
 from acto.post_process.post_diff_test import DiffTestResult, PostDiffTest
 from acto.snapshot import Snapshot

test/integration_tests/test_crdb_bugs.py

@@ -1,4 +1,5 @@
 """Integration tests for cockroach-operator bugs."""
+
 import json
 import os
 import pathlib
@@ -8,7 +9,7 @@
 
 from acto import acto_config
 from acto.checker.checker_set import CheckerSet
-from acto.input import DeterministicInputModel, InputModel
+from acto.input.input import DeterministicInputModel, InputModel
 from acto.lib.operator_config import OperatorConfig
 from acto.snapshot import Snapshot
 

test/integration_tests/test_data/elastic-on-k8s/config.json

@@ -0,0 +1,19 @@
+{
+    "deploy": {
+        "steps": [
+            {
+                "apply": {
+                    "file": "test/integration_tests/test_data/elastic-on-k8s/crds.yaml"
+                }
+            },
+            {
+                "apply": {
+                    "file": "test/integration_tests/test_data/elastic-on-k8s/operator.yaml",
+                    "operator": true
+                }
+            }
+        ]
+    },
+    "crd_name": "elasticsearches.elasticsearch.k8s.elastic.co",
+    "seed_custom_resource": "test/integration_tests/test_data/elastic-on-k8s/cr.yaml"
+}