in connectors/connectors_cli.py [0:0]
def list_jobs(obj, connector_id):
job_cli = Job(config=obj["config"]["elasticsearch"])
jobs = job_cli.list_jobs(connector_id=connector_id)
if len(jobs) == 0:
click.echo("No jobs found")
click.echo(f"Showing {len(jobs)} jobs \n")
table_rows = []
for job in jobs:
formatted_job = [
click.style(job.id, fg="green"),
click.style(job.connector_id, fg="white"),
click.style(job.index_name, fg="white"),
click.style(job.status.value, fg="white"),
click.style(job.job_type.value, fg="white"),
click.style(job.indexed_document_count, fg="white"),
click.style(job.indexed_document_volume, fg="white"),
click.style(job.deleted_document_count, fg="white"),
]
table_rows.append(formatted_job)
click.echo(
tabulate(
table_rows,
headers=[
"Job id",
"Connector id",
"Index name",
"Job status",
"Job type",
"Documents indexed",
"Volume documents indexed (MiB)",
"Documents deleted",
],
)
)