repo_description: Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
repo_topics: batch-processing data-analytics data-pipelines data-processing dataflow etl etl-framework iot-analytics kafka machine-learning-algorithms pathway python real-time rust stream-processing streaming time-series-analysis
code: // Copyright © 2026 Pathway
  
  use std::time::{SystemTime, UNIX_EPOCH};
  
  pub fn current_unix_timestamp_ms() -> u128 {
      SystemTime::now()
          .duration_since(UNIX_EPOCH)
          .expect("Failed to get the current timestamp")
          .as_millis()
  }
  
  pub fn current_unix_timestamp_secs() -> u64 {
      SystemTime::now()
          .duration_since(UNIX_EPOCH)
          .expect("Failed to get the current timestamp")
          .as_secs()
  }
  