diff --git a/beat/cmdline/algorithms.py b/beat/cmdline/algorithms.py index 396128772d4a7d0f955151257f82a5f526f7ed56..d658b984d08bf1ff6b71f8a92744873920f39015 100644 --- a/beat/cmdline/algorithms.py +++ b/beat/cmdline/algorithms.py @@ -45,7 +45,6 @@ from beat.core.execution import DockerExecutor from beat.core.dock import Host from beat.core import hash from beat.backend.python.algorithm import Storage as AlgorithmStorage -from beat.backend.python.algorithm import Algorithm from . import common from . import commands @@ -330,9 +329,7 @@ def execute_impl(prefix, cache, instructions_file): def get_dependencies(ctx, asset_name): prefix = ctx.meta["config"].path - alg = Algorithm(prefix, asset_name) - if not alg.valid: - raise RuntimeError("Invalid algortihm: {}".format(alg.errors)) + alg = algorithm.Algorithm(prefix, asset_name) dependencies = {} diff --git a/beat/cmdline/test/test_algorithms.py b/beat/cmdline/test/test_algorithms.py index 13573151fc78f72476f9e2d635aeb88be64f378f..a7a6a55b3ac735348c10e0a21d4784f06274250d 100644 --- a/beat/cmdline/test/test_algorithms.py +++ b/beat/cmdline/test/test_algorithms.py @@ -59,6 +59,7 @@ class TestOnline(core.OnlineAssetTestCase): "fork": "user/forked_obj/1", "push": "user/db_input_loop_processor/1", "not_owner_push": "v1/integers_add/1", + "push_invalid": "errors/description_too_long/1", } def _modify_asset(self, asset_name):