From c1e8a0b7971f4a5cbc3400e3e349afa794e1f729 Mon Sep 17 00:00:00 2001
From: iamvigneshwars <iamvigneshwars@gmail.com>
Date: Tue, 23 Apr 2024 09:52:37 +0000
Subject: [PATCH] Custom filter for aws sdk

---
 charts/processed_data/charts/processed_data/Chart.yaml | 2 +-
 processed_data/src/graphql/mod.rs                      | 2 +-
 processed_data/src/main.rs                             | 7 ++++++-
 3 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/charts/processed_data/charts/processed_data/Chart.yaml b/charts/processed_data/charts/processed_data/Chart.yaml
index 041da59..5646c99 100644
--- a/charts/processed_data/charts/processed_data/Chart.yaml
+++ b/charts/processed_data/charts/processed_data/Chart.yaml
@@ -5,4 +5,4 @@ type: application
 
 version: 0.1.0
 
-appVersion: 0.2.0-rc2
+appVersion: 0.2.1-rc1
diff --git a/processed_data/src/graphql/mod.rs b/processed_data/src/graphql/mod.rs
index b9d9ee4..03de594 100644
--- a/processed_data/src/graphql/mod.rs
+++ b/processed_data/src/graphql/mod.rs
@@ -411,7 +411,7 @@ impl AutoProcessing {
 
 #[ComplexObject]
 impl AutoProcFileAttachment {
-    /// Gives downloadable link for the processed image in the s3 bucket
+    /// Generate downloadable link for files in s3 bucket
     async fn file_url(&self, ctx: &Context<'_>) -> async_graphql::Result<String> {
         let s3_client = ctx.data::<aws_sdk_s3::Client>()?;
         let bucket = ctx.data::<S3Bucket>()?;
diff --git a/processed_data/src/main.rs b/processed_data/src/main.rs
index 3e1eb06..10169d9 100644
--- a/processed_data/src/main.rs
+++ b/processed_data/src/main.rs
@@ -29,7 +29,7 @@ use std::{
 };
 use tokio::net::TcpListener;
 use tracing::{info, instrument};
-use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
+use tracing_subscriber::{filter::FilterFn, layer::SubscriberExt, util::SubscriberInitExt};
 use url::Url;
 
 use crate::route_handlers::GraphQLHandler;
@@ -174,6 +174,10 @@ fn setup_telemetry(
     log_level: tracing::Level,
     otel_collector_url: Option<Url>,
 ) -> Result<(), anyhow::Error> {
+    let custom_filter = FilterFn::new(|metadata| {
+        !metadata.target().contains("aws_smithy_runtime")
+            && !metadata.target().contains("aws_credential_types")
+    });
     let level_filter = tracing_subscriber::filter::LevelFilter::from_level(log_level);
     let log_layer = tracing_subscriber::fmt::layer();
     let service_name_resource = opentelemetry_sdk::Resource::new(vec![
@@ -224,6 +228,7 @@ fn setup_telemetry(
     };
 
     tracing_subscriber::Registry::default()
+        .with(custom_filter)
         .with(level_filter)
         .with(log_layer)
         .with(metrics_layer)