feat(cli): fix upload ingest cli endpoint (datahub-project#8826)

asikowitz · Sep 12, 2023 · 138f6c0 · 138f6c0
1 parent 449cc9b
commit 138f6c0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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: {