diff options
Diffstat (limited to 'test/fixtures.py')
| -rw-r--r-- | test/fixtures.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/test/fixtures.py b/test/fixtures.py index bb6bc87..af4c145 100644 --- a/test/fixtures.py +++ b/test/fixtures.py @@ -11,14 +11,15 @@ from .service import ExternalService, SpawnedService from .testutil import get_open_port class Fixture(object): - project_root = os.environ.get('PROJECT_ROOT', os.path.abspath(os.path.join(os.path.dirname(__file__), ".."))) + kafka_version = os.environ.get('KAFKA_VERSION', '0.8.0') scala_version = os.environ.get("SCALA_VERSION", '2.8.0') - kafka_root = os.environ.get("KAFKA_ROOT", os.path.join(project_root, "kafka-src")) + project_root = os.environ.get('PROJECT_ROOT', os.path.abspath(os.path.join(os.path.dirname(__file__), ".."))) + kafka_root = os.environ.get("KAFKA_ROOT", os.path.join(project_root, 'servers', kafka_version, "kafka-src")) ivy_root = os.environ.get('IVY_ROOT', os.path.expanduser("~/.ivy2/cache")) @classmethod def test_resource(cls, filename): - return os.path.join(cls.project_root, "test", "resources", filename) + return os.path.join(cls.project_root, "servers", cls.kafka_version, "resources", filename) @classmethod def test_classpath(cls): |