diff --git a/cloud_pipelines_backend/launchers/kubernetes_launchers.py b/cloud_pipelines_backend/launchers/kubernetes_launchers.py
index b61e934..8415a91 100644
--- a/cloud_pipelines_backend/launchers/kubernetes_launchers.py
+++ b/cloud_pipelines_backend/launchers/kubernetes_launchers.py
@@ -43,6 +43,9 @@
 RESOURCES_SHARED_MEMORY_ANNOTATION_KEY = (
     "cloud-pipelines.net/launchers/generic/resources.shared_memory"
 )
+RESOURCES_EPHEMERAL_STORAGE_ANNOTATION_KEY = (
+    "cloud-pipelines.net/launchers/generic/resources.ephemeral_storage"
+)
 RESOURCES_ACCELERATORS_ANNOTATION_KEY = (
     "cloud-pipelines.net/launchers/generic/resources.accelerators"
 )
@@ -360,15 +363,16 @@ def get_output_path(output_name: str) -> str:
 
         annotations = annotations or {}
 
+        resources: k8s_client_lib.V1ResourceRequirements = (
+            main_container_spec.resources or k8s_client_lib.V1ResourceRequirements()
+        )
+        main_container_spec.resources = resources
+        resources.requests = resources.requests or {}
+        resources.limits = resources.limits or {}
+
         cpu_resource_request = annotations.get(RESOURCES_CPU_ANNOTATION_KEY)
         memory_resource_request = annotations.get(RESOURCES_MEMORY_ANNOTATION_KEY)
         if cpu_resource_request or memory_resource_request:
-            resources: k8s_client_lib.V1ResourceRequirements = (
-                main_container_spec.resources or k8s_client_lib.V1ResourceRequirements()
-            )
-            main_container_spec.resources = resources
-            resources.requests = resources.requests or {}
-            resources.limits = resources.limits or {}
             if cpu_resource_request:
                 resources.requests["cpu"] = cpu_resource_request
             if memory_resource_request:
@@ -393,6 +397,24 @@ def get_output_path(output_name: str) -> str:
             volume_map[volume.name] = volume
             volume_mounts.append(volume_mount)
 
+        ephemeral_storage_size = annotations.get(
+            RESOURCES_EPHEMERAL_STORAGE_ANNOTATION_KEY
+        )
+        if ephemeral_storage_size:
+            ephemeral_volume_name = "ephemeral-storage"
+            volume = k8s_client_lib.V1Volume(
+                name=ephemeral_volume_name,
+                empty_dir=k8s_client_lib.V1EmptyDirVolumeSource(),
+            )
+            volume_mount = k8s_client_lib.V1VolumeMount(
+                name=ephemeral_volume_name,
+                mount_path="/tmp",
+            )
+            volume_map[volume.name] = volume
+            volume_mounts.append(volume_mount)
+            # Specifying the ephemeral storage resource request
+            resources.requests["ephemeral-storage"] = ephemeral_storage_size
+
         # Optionally adding the IPC_LOCK capability that may be needed for InfiniBand.
         # ContainerSpec.securityContext.capabilities.add=["IPC_LOCK"]
         enable_capability_ipc_lock: str = annotations.get(