/opt/hostedtoolcache/Python/3.8.12/x64/lib/python3.8/site-packages/urllib3/util/retry.py:38: DeprecationWarning: Using 'Retry.DEFAULT_METHOD_WHITELIST' is deprecated and will be removed in v2.0. Use 'Retry.DEFAULT_ALLOWED_METHODS' instead
    warnings.warn(

feathr_project/test/test_config_loading.py: 2 warnings
feathr_project/test/test_feature_materialization.py: 3 warnings
feathr_project/test/test_azure_snowflake_e2e.py: 2 warnings
feathr_project/test/test_azure_spark_e2e.py: 3 warnings
feathr_project/test/test_feature_registry.py: 1 warning
feathr_project/test/test_input_output_sources.py: 2 warnings
feathr_project/test/test_pyduf_preprocessing_e2e.py: 5 warnings
  /opt/hostedtoolcache/Python/3.8.12/x64/lib/python3.8/site-packages/databricks_cli/sdk/api_client.py:75: DeprecationWarning: Using 'method_whitelist' with Retry is deprecated and will be removed in v2.0. Use 'allowed_methods' instead

    def test_feathr_online_store_agg_features():
        """
        Test FeathrClient() get_online_features and batch_get can get feature data correctly.
        """
        test_workspace_dir = Path(__file__).parent.resolve() / "test_user_workspace"
    
        client = snowflake_test_setup(os.path.join(test_workspace_dir, "feathr_config.yaml"))
    
        online_test_table = get_online_test_table_name("snowflakeSampleDemoFeature")
    
        backfill_time = BackfillTime(start=datetime(2020, 5, 20), end=datetime(2020, 5, 20), step=timedelta(days=1))
        redisSink = RedisSink(table_name= online_test_table)
        settings = MaterializationSettings(name="snowflakeSampleDemoFeature",
                                       sinks=[redisSink],
                                       feature_names=['f_snowflake_call_center_division_name',
                                                      'f_snowflake_call_center_zipcode'],
                                       backfill_time=backfill_time)
        client.materialize_features(settings)
        # just assume the job is successful without validating the actual result in Redis. Might need to consolidate
        # this part with the test_feathr_online_store test case
        client.wait_job_to_finish(timeout_sec=900)
    
        res = client.get_online_features(online_test_table, '1',
                                         ['f_snowflake_call_center_division_name', 'f_snowflake_call_center_zipcode'])
    
        assert len(res) == 2
        assert res[0] != None
        assert res[1] != None
        res = client.multi_get_online_features('snowflakeSampleDemoFeature',
                                        ['1', '2'],
                                        ['f_snowflake_call_center_division_name', 'f_snowflake_call_center_zipcode'])
>       assert res['1'][0] != None
E       assert None != None