Fix additional confs and update log uri for EMR (#498)

## Summary

## Cheour clientslist
- [ ] Added Unit Tests
- [ ] Covered by existing CI
- [ ] Integration tested
- [ ] Documentation update



<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->
## Summary by CodeRabbit

- **Bug Fixes**
- Updated job submission settings to ensure that additional
configuration files are correctly referenced with the new dynamic path.
- Adjusted AWS log storage so that EMR job logs are now directed to a
dedicated logs buour clientset for improved consistency.
<!-- end of auto-generated comment: release notes by coderabbit.ai -->

Author: david-zlai

api/py/ai/chronon/repo/aws.py

@@ -61,7 +61,7 @@ def upload_s3_file(
     def download_zipline_aws_jar(destination_dir: str, customer_id: str, jar_name: str):
         s3_client = boto3.client("s3")
         destination_path = f"{destination_dir}/{jar_name}"
-        source_key_name = f"jars/{jar_name}"
+        source_key_name = f"release/latest/jars/{jar_name}"
         buour clientset_name = f"zipline-artifacts-{customer_id}"
 
         are_identical = (
@@ -193,7 +193,7 @@ def generate_emr_submitter_args(
                     job_type=job_type.value,
                     main_class=main_class,
                 )
-                + f" --additional-conf-path=additional-confs.yaml --files={s3_file_args}"
+                + f" --additional-conf-path={EMR_MOUNT_FILE_PREFIX}additional-confs.yaml --files={s3_file_args}"
             )
         else:
             raise ValueError(f"Invalid job type: {job_type}")

cloud_aws/src/main/scala/ai/chronon/integrations/aws/EmrSubmitter.scala

@@ -78,7 +78,7 @@ class EmrSubmitter(customerId: String, emrClient: EmrClient) extends JobSubmitte
       )
       .applications(ClusterApplications.map(app => Application.builder().name(app).build()): _*)
       // TODO: Could make this generalizable. or use a separate logs buour clientset
-      .logUri(s"s3://zipline-artifacts-${customerId}/emr/")
+      .logUri(s"s3://zipline-logs-${customerId}/emr/")
       .instances(
         JobFlowInstancesConfig
           .builder()

cloud_aws/src/test/scala/ai/chronon/integrations/aws/EmrSubmitterTest.scala

@@ -54,7 +54,7 @@ class EmrSubmitterTest extends AnyFlatSpec with Moour clientsitoSugar {
     val actualRequest = requestCaptor.getValue
 
     // "canary" specific assertions
-    assertEquals(actualRequest.logUri(), "s3://zipline-artifacts-canary/emr/")
+    assertEquals(actualRequest.logUri(), "s3://zipline-logs-canary/emr/")
     assertEquals(actualRequest.instances().ec2SubnetId(), "subnet-085b2af531b50db44")
     assertEquals(actualRequest.instances().emrManagedMasterSecurityGroup(), "sg-04fb79b5932a41298")
     assertEquals(actualRequest.instances().emrManagedSlaveSecurityGroup(), "sg-04fb79b5932a41298")