From 138f6c0f74a4799d31560e9fde19ef6011089990 Mon Sep 17 00:00:00 2001 From: Pedro Silva Date: Tue, 12 Sep 2023 22:26:30 +0100 Subject: [PATCH] feat(cli): fix upload ingest cli endpoint (#8826) --- metadata-ingestion/src/datahub/cli/ingest_cli.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/metadata-ingestion/src/datahub/cli/ingest_cli.py b/metadata-ingestion/src/datahub/cli/ingest_cli.py index 42c0ea1601c74..5931bf89b010b 100644 --- a/metadata-ingestion/src/datahub/cli/ingest_cli.py +++ b/metadata-ingestion/src/datahub/cli/ingest_cli.py @@ -282,12 +282,14 @@ def deploy( "urn": urn, "name": name, "type": pipeline_config["source"]["type"], - "schedule": {"interval": schedule, "timezone": time_zone}, "recipe": json.dumps(pipeline_config), "executorId": executor_id, "version": cli_version, } + if schedule is not None: + variables["schedule"] = {"interval": schedule, "timezone": time_zone} + if urn: if not datahub_graph.exists(urn): logger.error(f"Could not find recipe for provided urn: {urn}") @@ -331,6 +333,7 @@ def deploy( $version: String) { createIngestionSource(input: { + name: $name, type: $type, schedule: $schedule, config: {