mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-31 12:10:31 +08:00
STY: Rename run_algo to run_pipeline.
This commit is contained in:
+2
-2
@@ -17,9 +17,9 @@
|
||||
import sys
|
||||
|
||||
import zipline
|
||||
from zipline.utils import parse_args, run_algo
|
||||
from zipline.utils import parse_args, run_pipeline
|
||||
|
||||
if __name__ == "__main__":
|
||||
parsed = parse_args(sys.argv[1:])
|
||||
run_algo(print_algo=True, **parsed)
|
||||
run_pipeline(print_algo=True, **parsed)
|
||||
sys.exit(0)
|
||||
|
||||
@@ -13,6 +13,6 @@
|
||||
# See the License for the specific language governing permissions and
|
||||
# limitations under the License.
|
||||
|
||||
from .cli import run_algo, parse_args, parse_cell_magic
|
||||
from .cli import run_pipeline, parse_args, parse_cell_magic
|
||||
|
||||
__all__ = ['run_algo', 'parse_args', 'parse_cell_magic']
|
||||
__all__ = ['run_pipeline', 'parse_args', 'parse_cell_magic']
|
||||
|
||||
@@ -121,7 +121,7 @@ def parse_cell_magic(line, cell):
|
||||
if not local_namespace:
|
||||
args['namespace'] = get_ipython().user_ns # flake8: noqa
|
||||
|
||||
perf = run_algo(print_algo=False, algo_text=cell, **args)
|
||||
perf = run_pipeline(print_algo=False, algo_text=cell, **args)
|
||||
|
||||
# If we are running inside NB, do not output to file but create a
|
||||
# variable instead
|
||||
@@ -130,7 +130,7 @@ def parse_cell_magic(line, cell):
|
||||
get_ipython().user_ns[output_var_name] = perf # flake8: noqa
|
||||
|
||||
|
||||
def run_algo(print_algo=True, **kwargs):
|
||||
def run_pipeline(print_algo=True, **kwargs):
|
||||
"""Runs a full zipline pipeline given configuration keyword
|
||||
arguments.
|
||||
|
||||
|
||||
Reference in New Issue
Block a user