Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 343 for queues (0.04 sec)

  1. cmd/sftp-server-driver.go

    	_ = w.r.CloseWithError(err)
    	w.err = err
    }
    
    func (w *writerAt) Close() (err error) {
    	switch {
    	case len(w.buffer) > 0:
    		err = errors.New("some file segments were not flushed from the queue")
    		_ = w.w.CloseWithError(err)
    	case w.err != nil:
    		// No need to close here since both pipes were
    		// closing inside TransferError()
    		err = w.err
    	default:
    		err = w.w.Close()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  2. tensorflow/c/eager/parallel_device/parallel_device_lib.h

      // re-use a thread.
      std::vector<std::unique_ptr<DeviceThread>> device_threads_;
      // A cancellation manager to use if the caller does not provide one. When ops
      // are executed asynchronously this must outlive the queued op, so it can't be
      // function-local to Execute.
      mutable std::unique_ptr<CancellationManager> default_cancellation_manager_;
    };
    
    // Contains a tuple of tensors, one on each of the `underlying_devices_` of the
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. go.mod

    	github.com/docker/go-units v0.5.0 // indirect
    	github.com/eapache/go-resiliency v1.7.0 // indirect
    	github.com/eapache/go-xerial-snappy v0.0.0-20230731223053-c322873962e3 // indirect
    	github.com/eapache/queue v1.1.0 // indirect
    	github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f // indirect
    	github.com/fatih/structs v1.1.0 // indirect
    	github.com/felixge/httpsnoop v1.0.4 // indirect
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. docs/pt/docs/tutorial/dependencies/dependencies-with-yield.md

    Se você lançar qualquer exceção, ela será passada para as dependências com yield, inlcuindo a `HTTPException`. Na maioria dos casos você vai querer relançar essa mesma exceção ou uma nova a partir da dependência com `yield` para garantir que ela seja tratada adequadamente.
    
    ///
    
    ## Dependências com `yield`, `HTTPException`, `except` e Tarefas de Background
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  5. docs/en/data/external_links.yml

    I'm Leaving Flask - author: Mike Moritz author_link: https://medium.com/@mike.p.moritz link: https://medium.com/@mike.p.moritz/using-docker-compose-to-deploy-a-lightweight-python-rest-api-with-a-job-queue-37e6072a209b title: Using Docker Compose to deploy a lightweight Python REST API with a job queue - author: '@euri10' author_link: https://gitlab.com/euri10 link: https://gitlab.com/euri10/fastapi_cheatsheet title: A FastAPI and Swagger UI visual cheatsheet - author: Uber Engineering author_link:...
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Oct 24 18:39:34 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  6. internal/event/target/nats.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of NATS `%s`: %w", id, err)
    		}
    	}
    
    	target := &NATSTarget{
    		id:         event.TargetID{ID: id, Name: "nats"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  7. cmd/admin-bucket-handlers.go

    		select {
    		case entry, ok := <-diffCh:
    			if !ok {
    				return
    			}
    			if err := enc.Encode(entry); err != nil {
    				return
    			}
    			if len(diffCh) == 0 {
    				// Flush if nothing is queued
    				w.(http.Flusher).Flush()
    			}
    		case <-keepAliveTicker.C:
    			if len(diffCh) > 0 {
    				continue
    			}
    			if _, err := w.Write([]byte(" ")); err != nil {
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/adminlte.min.js.map

    hide()\n    }\n\n    // Collapse the control sidebar\n    if (this._config.controlsidebarSlide) {\n      $html.addClass(CLASS_NAME_CONTROL_SIDEBAR_ANIMATE)\n      $(this._config.target).show().delay(10).queue(function () {\n        $body.addClass(CLASS_NAME_CONTROL_SIDEBAR_SLIDE).delay(300).queue(function () {\n          $html.removeClass(CLASS_NAME_CONTROL_SIDEBAR_ANIMATE)\n          $(this).dequeue()\n        })\n        $(this).dequeue()\n      })\n    } else {\n      $body.addClass(CLASS_NAM...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 132.4K bytes
    - Viewed (0)
  9. docs/pt/docs/deployment/docker.md

    ### Contêineres com Múltiplos Processos e Casos Especiais
    
    Claro, existem **casos especiais** em que você pode querer ter um **contêiner** com um **gerenciador de processos Gunicorn** iniciando vários **processos trabalhadores Uvicorn** dentro.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 12 21:47:53 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

                urlFilterService.delete(sid);
            } catch (final Exception e) {
                logger.warn("Failed to delete UrlFilter for {}", sid, e);
            }
    
            try {
                // clear queue
                urlQueueService.clearCache();
                urlQueueService.delete(sid);
            } catch (final Exception e) {
                logger.warn("Failed to delete UrlQueue for {}", sid, e);
            }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 22.6K bytes
    - Viewed (0)
Back to top