CLI convoke + docker image

Makefile

@@ -12,4 +12,8 @@ test-benchmark:
 
 .PHONY: start-backing-services
 start-backing-services:
-	docker-compose -f dev/kafka-single.yml up -d
+	docker-compose -f dev/kafka-single.yml up -d
+
+.PHONY: docker-image
+docker-image:
+	docker build -t turbolytics/sql-flow .

cmd/sql-flow.py

@@ -1,4 +1,6 @@
 import click
+import duckdb
+
 from sqlflow import logging
 from sqlflow.config import new_from_path
 from sqlflow.lifecycle import start, invoke
@@ -31,14 +33,15 @@ def dev():
     pass
 
 
-@click.command()
+@click.command(name='invoke')
 @click.argument('config')
 @click.argument('fixture')
-def invoke(config, fixture):
-    invoke(config, fixture)
+def cli_invoke(config, fixture):
+    conn = duckdb.connect()
+    invoke(conn, config, fixture)
 
 
-dev.add_command(invoke)
+dev.add_command(cli_invoke)
 cli.add_command(run)
 cli.add_command(dev)