diff options
| author | Dennis Fink | 2019-08-27 13:20:40 +0200 |
|---|---|---|
| committer | Dennis Fink | 2019-08-27 13:20:40 +0200 |
| commit | ffbd03cdd6771bbfbeff412cb0df2d355d9f7599 (patch) | |
| tree | 68b3f437d42e57bf5f5d5f860df67f7b0c75c2ba | |
| parent | d67140e7be23c810a049af902f1c6e547d68337c (diff) | |
| download | patternutils-ffbd03cdd6771bbfbeff412cb0df2d355d9f7599.tar.gz patternutils-ffbd03cdd6771bbfbeff412cb0df2d355d9f7599.zip | |
Added stream option to targs
| -rw-r--r-- | patternutils/commands/targs.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/patternutils/commands/targs.py b/patternutils/commands/targs.py index 9bdf213..63955ae 100644 --- a/patternutils/commands/targs.py +++ b/patternutils/commands/targs.py @@ -49,6 +49,8 @@ def run_command( help='Redirect stdout to /dev/null') @click.option('--redirect-stderr', is_flag=True, default=False, help='Redirect stderr to /dev/null') +@click.option('--stream', if_flag=True, defaults=False, + help='Input is a stream of JSON objects') @click.version_option() @click.argument('command') def targs( @@ -60,11 +62,15 @@ def targs( redirect_stdout: bool, redirect_stderr: bool, use_predefined_template: bool, + stream: bool, verbose: bool, ) -> None: try: - data = json.load(read_from) # type: ignore + if not stream: + data = json.load(read_from) # type: ignore + else: + data = [json.loads(line) for line in read_from] except json.JSONDecodeError: click.secho('JSON not valid!', fg='red', err=True) raise SystemExit |
