oops

PeerDB-io · Mar 21, 2024 · 2864ca5 · 2864ca5
1 parent ef41e08
commit 2864ca5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/kafka/kafka.go b/flow/connectors/kafka/kafka.go
@@ -164,7 +164,6 @@ func loadScript(ctx context.Context, script string, printfn lua.LGFunction) (*lu
 	}
 
 	ls := lua.NewState(lua.Options{SkipOpenLibs: true})
-	defer ls.Close()
 	ls.SetContext(ctx)
 	for _, pair := range []struct {
 		n string
@@ -270,6 +269,7 @@ func (c *KafkaConnector) SyncRecords(ctx context.Context, req *model.SyncRecords
 	if err != nil {
 		return nil, err
 	}
+	defer ls.Close()
 
 	lfn := ls.Env.RawGetString("onRecord")
 	fn, ok := lfn.(*lua.LFunction)