diff --git a/flow/cmd/version.go b/flow/cmd/version.go
new file mode 100644
index 0000000000..58074fa75c
--- /dev/null
+++ b/flow/cmd/version.go
@@ -0,0 +1,16 @@
+package main
+
+import (
+	"context"
+
+	"github.com/PeerDB-io/peer-flow/connectors/utils"
+	"github.com/PeerDB-io/peer-flow/generated/protos"
+)
+
+func (h *FlowRequestHandler) GetVersion(
+	ctx context.Context,
+	req *protos.PeerDBVersionRequest,
+) (*protos.PeerDBVersionResponse, error) {
+	version := utils.GetEnvString("PEERDB_VERSION_SHA_SHORT", "unknown")
+	return &protos.PeerDBVersionResponse{Version: version}, nil
+}