wassname/catalyst
1
0
Fork 0
mirror of https://github.com/wassname/catalyst.git synced 2026-07-02 07:36:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

Added param checking and help msg to clean bundle folders

Browse Source
This commit is contained in:
Victor Grau Serrat
2017-10-23 21:30:48 -06:00
parent 3c10d19a7e
commit 565e9a3cea
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
catalyst/__main__.py
+9 -2
View File
@@ -525,7 +525,14 @@ def ingest_exchange(exchange_name, data_frequency, start, end,
help='The bundle data frequency to remove. If not specified, it will '
'remove both daily and minute bundles.',
)
def clean_exchange(exchange_name, data_frequency):
@click.pass_context
def clean_exchange(ctx, exchange_name, data_frequency):
"""Clean up bundles from 'ingest-exchange'.
"""
if exchange_name is None:
ctx.fail("must specify an exchange name '-x'")
exchange = get_exchange(exchange_name)
exchange_bundle = ExchangeBundle(exchange)
@@ -625,7 +632,7 @@ def ingest(ctx, bundle, exchange_name, compile_locally, assets_version,
' This may not be passed with -e / --before or -a / --after',
)
def clean(bundle, before, after, keep_last):
"""Clean up data downloaded with the ingest command.
"""Clean up bundles from 'ingest'.
"""
bundles_module.clean(
bundle,