Skip to content

Commit

Permalink
WX-927 Quieter progress on GCP Batch (#7563)
Browse files Browse the repository at this point in the history
  • Loading branch information
mcovarr authored Oct 24, 2024
1 parent 6e21229 commit 3b75b19
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1008,7 +1008,6 @@ class GcpBatchAsyncBackendJobExecutionActor(override val standardParams: Standar

for {
_ <- Future.unit // trick to get into a future context
_ = log.info(s"started polling for $jobNameStr")
jobName = JobName.parse(jobNameStr)
status <- pollStatus(workflowId, jobName, backendSingletonActor, initializationData.requestFactory)
} yield status
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ object BatchRequestExecutor {

def execute(groupedRequests: GcpBatchGroupedRequests)(implicit ec: ExecutionContext): Future[List[Try[Unit]]] = {
val requests = groupedRequests.entries
logger.info(s"Execute ${requests.size} requests")

if (requests.isEmpty) Future.successful(List.empty)
else nonEmptyExecute(requests)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@ trait GetRequestHandler extends LazyLogging { this: RequestHandler =>
val _ = resultF
.map {
case Success(BatchApiResponse.StatusQueried(status)) =>
logger.info(s"Get operation succeeded for ${pollRequest.jobId.jobId}: $status")
pollRequest.requester ! status
Success(())

Expand Down

0 comments on commit 3b75b19

Please sign in to comment.