diff --git a/funnel-udf/src/steps.rs b/funnel-udf/src/steps.rs index 9330caf4e1c..21d6fb84e62 100644 --- a/funnel-udf/src/steps.rs +++ b/funnel-udf/src/steps.rs @@ -55,7 +55,7 @@ const DEFAULT_ENTERED_TIMESTAMP: EnteredTimestamp = EnteredTimestamp { }; pub fn process_line(line: &str) -> Value { - let args = parse_args(&line); + let args = parse_args(line); let mut aggregate_funnel_row = AggregateFunnelRow { results: Vec::with_capacity(args.prop_vals.len()), breakdown_step: Option::None, @@ -112,7 +112,7 @@ impl AggregateFunnelRow { self.process_event( args, &mut vars, - &events_with_same_timestamp[0], + events_with_same_timestamp[0], prop_val, false ); @@ -147,7 +147,7 @@ impl AggregateFunnelRow { args, &mut vars, &event, - &prop_val, + prop_val, true ); } @@ -261,4 +261,4 @@ impl AggregateFunnelRow { } } } -} \ No newline at end of file +} diff --git a/funnel-udf/src/trends.rs b/funnel-udf/src/trends.rs index fa7dc162c12..42356dc06d1 100644 --- a/funnel-udf/src/trends.rs +++ b/funnel-udf/src/trends.rs @@ -81,7 +81,7 @@ const DEFAULT_ENTERED_TIMESTAMP: EnteredTimestamp = EnteredTimestamp { }; pub fn process_line(line: &str) -> Value { - let args = parse_args(&line); + let args = parse_args(line); let mut aggregate_funnel_row = AggregateFunnelRow { results: HashMap::new(), breakdown_step: Option::None, @@ -128,7 +128,7 @@ impl AggregateFunnelRow { self.process_event( args, &mut vars, - &event, + event, prop_val, ); } @@ -242,4 +242,4 @@ impl AggregateFunnelRow { } } } -} \ No newline at end of file +}