fix linter warnings

Author: KSDaemon

packages/cubejs-backend-native/js/ResultWrapper.ts

@@ -57,7 +57,7 @@ export class ResultWrapper extends BaseWrapper implements DataResult {
           const array = this.getArray();
           const l = array.length;
 
-          return function* () {
+          return function* yieldArrayItem () {
             for (let i = 0; i < l; i++) {
               yield array[i];
             }

packages/cubejs-backend-native/src/orchestrator.rs

@@ -31,12 +31,6 @@ pub fn register_module(cx: &mut ModuleContext) -> NeonResult<()> {
     Ok(())
 }
 
-// #[derive(Debug, Clone)]
-// pub enum ResultWrapperData {
-//     JsObj(RecordBatch),
-//     Native()
-// }
-
 #[derive(Debug, Clone)]
 pub struct ResultWrapper {
     transform_data: TransformDataRequest,

packages/cubejs-backend-native/test/sql.test.ts

@@ -6,7 +6,7 @@ import * as native from '../js';
 import metaFixture from './meta';
 import { FakeRowStream } from './response-fake';
 
-const logger = jest.fn(({ event }) => {
+const _logger = jest.fn(({ event }) => {
   if (
     !event.error.includes(
       'load - strange response, success which contains error'

rust/cubesql/cubesql/src/compile/engine/df/scan.rs

@@ -1131,7 +1131,7 @@ pub fn transform_response<V: ValueObject>(
                                     ))
                                 })?;
                             // TODO switch parsing to microseconds
-                            if timestamp.timestamp_millis() > (((1i64) << 62) / 1_000_000) {
+                            if timestamp.and_utc().timestamp_millis() > (((1i64) << 62) / 1_000_000) {
                                 builder.append_null()?;
                             } else if let Some(nanos) = timestamp.timestamp_nanos_opt() {
                                 builder.append_value(nanos)?;
@@ -1173,10 +1173,10 @@ pub fn transform_response<V: ValueObject>(
                                     ))
                                 })?;
                             // TODO switch parsing to microseconds
-                            if timestamp.timestamp_millis() > (((1 as i64) << 62) / 1_000_000) {
+                            if timestamp.and_utc().timestamp_millis() > (((1 as i64) << 62) / 1_000_000) {
                                 builder.append_null()?;
                             } else {
-                                builder.append_value(timestamp.timestamp_millis())?;
+                                builder.append_value(timestamp.and_utc().timestamp_millis())?;
                             }
                         },
                     },

rust/cubesql/cubesql/src/compile/engine/udf/common.rs

@@ -1029,6 +1029,7 @@ pub fn create_date_udf() -> ScalarUDF {
                         builder.append_value(
                             NaiveDateTime::parse_from_str(strings.value(i), "%Y-%m-%d %H:%M:%S%.f")
                                 .map_err(|e| DataFusionError::Execution(e.to_string()))?
+                                .and_utc()
                                 .timestamp_nanos_opt()
                                 .unwrap(),
                         )?;
@@ -1233,6 +1234,7 @@ macro_rules! date_math_udf {
                 let interval = intervals.value(i).into();
                 builder.append_value(
                     $FUN(timestamp, interval, $IS_ADD)?
+                        .and_utc()
                         .timestamp_nanos_opt()
                         .unwrap(),
                 )?;
@@ -1572,7 +1574,7 @@ pub fn create_str_to_date_udf() -> ScalarUDF {
             })?;
 
             Ok(ColumnarValue::Scalar(ScalarValue::TimestampNanosecond(
-                Some(res.timestamp_nanos_opt().unwrap()),
+                Some(res.and_utc().timestamp_nanos_opt().unwrap()),
                 None,
             )))
         });
@@ -2345,7 +2347,7 @@ macro_rules! generate_series_helper_timestamp {
             ))
         })?;
         let res = date_addsub_month_day_nano(current_dt, $STEP, true)?;
-        $CURRENT = res.timestamp_nanos_opt().unwrap() as $PRIMITIVE_TYPE;
+        $CURRENT = res.and_utc().timestamp_nanos_opt().unwrap() as $PRIMITIVE_TYPE;
     };
 }
 
@@ -3230,6 +3232,7 @@ pub fn create_date_to_timestamp_udf() -> ScalarUDF {
                             )?;
                             Ok(Some(
                                 NaiveDateTime::new(date, time)
+                                    .and_utc()
                                     .timestamp_nanos_opt()
                                     .unwrap(),
                             ))

rust/cubesql/cubesql/src/compile/rewrite/rules/filters.rs

@@ -4117,8 +4117,8 @@ impl FilterRules {
             };
 
             let (Some(start_date), Some(end_date)) = (
-                start_date.timestamp_nanos_opt(),
-                end_date.timestamp_nanos_opt(),
+                start_date.and_utc().timestamp_nanos_opt(),
+                end_date.and_utc().timestamp_nanos_opt(),
             ) else {
                 return false;
             };