|
1 | 1 | import logging |
| 2 | +import time |
2 | 3 | from datetime import timedelta |
3 | | -from time import perf_counter |
4 | 4 |
|
5 | 5 | import click |
6 | 6 |
|
|
9 | 9 | logger = logging.getLogger(__name__) |
10 | 10 |
|
11 | 11 |
|
12 | | -@click.command() |
| 12 | +@click.group("embeddings") |
13 | 13 | @click.option( |
14 | | - "-v", "--verbose", is_flag=True, help="Pass to log at debug level instead of info" |
| 14 | + "-v", |
| 15 | + "--verbose", |
| 16 | + is_flag=True, |
| 17 | + help="Pass to log at debug level instead of info", |
15 | 18 | ) |
16 | | -def main(*, verbose: bool) -> None: |
17 | | - start_time = perf_counter() |
| 19 | +@click.pass_context |
| 20 | +def main( |
| 21 | + ctx: click.Context, |
| 22 | + *, |
| 23 | + verbose: bool, |
| 24 | +) -> None: |
| 25 | + ctx.ensure_object(dict) |
| 26 | + ctx.obj["start_time"] = time.perf_counter() |
| 27 | + |
18 | 28 | root_logger = logging.getLogger() |
19 | 29 | logger.info(configure_logger(root_logger, verbose=verbose)) |
20 | 30 | logger.info(configure_sentry()) |
21 | 31 | logger.info("Running process") |
22 | 32 |
|
23 | | - # Do things here! |
| 33 | + def _log_command_elapsed_time() -> None: |
| 34 | + elapsed_time = time.perf_counter() - ctx.obj["start_time"] |
| 35 | + logger.info( |
| 36 | + "Total time to complete process: %s", str(timedelta(seconds=elapsed_time)) |
| 37 | + ) |
| 38 | + |
| 39 | + ctx.call_on_close(_log_command_elapsed_time) |
| 40 | + |
| 41 | + |
| 42 | +@main.command() |
| 43 | +def ping() -> None: |
| 44 | + """Emit 'pong' to debug logs and stdout.""" |
| 45 | + logger.debug("pong") |
| 46 | + click.echo("pong") |
| 47 | + |
24 | 48 |
|
25 | | - elapsed_time = perf_counter() - start_time |
26 | | - logger.info( |
27 | | - "Total time to complete process: %s", str(timedelta(seconds=elapsed_time)) |
28 | | - ) |
| 49 | +if __name__ == "__main__": # pragma: no cover |
| 50 | + logger = logging.getLogger("embeddings.main") |
| 51 | + main() |
0 commit comments