diff --git a/meter-macros/src/read_meter.rs b/meter-macros/src/read_meter.rs
index 5651caa..da73477 100644
--- a/meter-macros/src/read_meter.rs
+++ b/meter-macros/src/read_meter.rs
@@ -71,7 +71,7 @@ macro_rules! read_meter {
                 catalog: $catalog.into(),
                 schema: $schema.into(),
                 value: value,
-                source: source,
+                source: $source,
             };
             meter_core::global::global_registry().record_read(record);
         }
diff --git a/meter-macros/src/write_meter.rs b/meter-macros/src/write_meter.rs
index a27fe5c..8579ca0 100644
--- a/meter-macros/src/write_meter.rs
+++ b/meter-macros/src/write_meter.rs
@@ -65,7 +65,7 @@ macro_rules! write_meter {
                 catalog: $catalog.into(),
                 schema: $schema.into(),
                 value: value,
-                source: source,
+                source: $source,
             };
 
             r.record_write(record);