diff --git a/datafusion/core/src/execution/context.rs b/datafusion/core/src/execution/context.rs
index d25f96f649043..c06a71a6ac09b 100644
--- a/datafusion/core/src/execution/context.rs
+++ b/datafusion/core/src/execution/context.rs
@@ -1803,6 +1803,11 @@ impl SessionState {
     pub fn aggregate_functions(&self) -> &HashMap<String, Arc<AggregateUDF>> {
         &self.aggregate_functions
     }
+
+    /// Return version of the cargo package that produced this query
+    pub fn version(&self) -> &str {
+        env!("CARGO_PKG_VERSION")
+    }
 }
 
 struct SessionContextProvider<'a> {