Search Results

import polars as pl chunk_size = 1000  # Adjust based on available memorydataframes = [] for i in range(0, len(a_list), chunk_size):    chunk = a_list[i:i + chunk_size]    dataframes.append(pl.DataFrame(chunk, schema=["stsdf", "abc"])) combined_df = pl.conc...

import polars as pl def flag_offline_periods(df):    # Count entries per bucket    counts = df.groupby('timestamp_bucket').agg(pl.count('*').alias('count'))        # Identify buckets with more than 20 entries    high_count_buckets = counts.filter(pl.col('coun...

categories/any(c:c eq 'Holiday') and start/Datetime ge '@{startOfDay(addDays(utcNow(),1),'yyyy-MM-ddTHH:mmZ')}'     Title eq '@{items('Apply_to_each')['Subject']}' and Date eq '@{formatDateTime(items('Apply_to_each')['Start'], 'yyyy-MM-ddTHH:mm:ssZ')}' and ...