updated error handling

viant · Aug 16, 2024 · 94e34b1 · 94e34b1
1 parent d9e060f
commit 94e34b1
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/service/operator/async.go b/service/operator/async.go
@@ -79,6 +79,7 @@ func (s *Service) updateJobStatusDone(ctx context.Context, aComponent *repositor
 }
 
 var queryParameter = state.NewParameter("Query", state.NewQueryLocation(""), state.WithParameterSchema(state.NewSchema(reflect.TypeOf(""))))
+var textLimit = 63 * 1024
 
 func (s *Service) buildJob(ctx context.Context, aSession *session.Session, aState *structology.State, aComponent *repository.Component, matchKey string, options *session.Options) (*async.Job, error) {
  asyncModule := aComponent.Async
@@ -93,6 +94,9 @@ func (s *Service) buildJob(ctx context.Context, aSession *session.Session, aStat
  if err != nil {
  return nil, err
  }
+ if len(encodedState) > textLimit {
+ encodedState = encodedState[:textLimit]
+ }
  UUID, err := uuid.NewUUID()
  if err != nil {
  return nil, err