Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 244 for Celery (0.09 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/bucket-handlers.go

    // ----------
    // Places an Object Lock configuration on the specified bucket. The rule
    // specified in the Object Lock configuration will be applied by default
    // to every new object placed in the specified bucket.
    func (api objectAPIHandlers) PutBucketObjectLockConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketObjectLockConfig")
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool-rebalance.go

    	doneCh := make(chan error, 1)
    	defer xioutil.SafeClose(doneCh)
    
    	// Save rebalance.bin periodically.
    	go func() {
    		// Update rebalance.bin periodically once every 5-10s, chosen randomly
    		// to avoid multiple pool leaders herding to update around the same
    		// time.
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		randSleepFor := func() time.Duration {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  3. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

          return delegate.isCancelled();
        }
      }
    
      /**
       * A {@link Scheduler} that provides a convenient way for the {@link AbstractScheduledService} to
       * use a dynamically changing schedule. After every execution of the task, assuming it hasn't been
       * cancelled, the {@link #getNextSchedule} method will be called.
       *
       * @author Luke Sandberg
       * @since 11.0
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.8K bytes
    - Click Count (0)
  4. docs/en/docs/alternatives.md

    These features are what Marshmallow was built to provide. It is a great library, and I have used it a lot before.
    
    But it was created before there existed Python type hints. So, to define every <abbr title="the definition of how data should be formed">schema</abbr> you need to use specific utils and classes provided by Marshmallow.
    
    /// check | Inspired **FastAPI** to
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  5. android/guava-testlib/src/com/google/common/collect/testing/MapInterfaceTest.java

        assertFalse(entrySet.contains("foo"));
      }
    
      /**
       * Override this to check invariants which should hold true for a particular implementation, but
       * which are not generally applicable to every instance of Map.
       *
       * @param map the map whose additional invariants to check.
       */
      protected void assertMoreInvariants(Map<K, V> map) {}
    
      public void testClear() {
        Map<K, V> map;
        try {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Aug 11 19:31:30 GMT 2025
    - 43.9K bytes
    - Click Count (0)
  6. scripts/translate.py

            ////
            »»»
    
        Result (German):
    
            «««
            //// tab | Linux, macOS, Windows Bash
            Hallo wieder
            ////
            »»»
    
    
    ### Headings
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 19:05:53 GMT 2025
    - 34.1K bytes
    - Click Count (0)
  7. cmd/common-main.go

    			err = fmt.Errorf("Unable to load TLS certificate '%s,%s': %w", certFile, keyFile, err)
    			bootLogIf(GlobalContext, err, logger.ErrorKind)
    		}
    	}
    	secureConn = true
    
    	// Certs might be symlinks, reload them every 10 seconds.
    	manager.UpdateReloadDuration(10 * time.Second)
    
    	// syscall.SIGHUP to reload the certs.
    	manager.ReloadOnSignal(syscall.SIGHUP)
    
    	return x509Certs, manager, secureConn, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  8. src/main/java/jcifs/internal/smb1/ServerMessageBlock.java

         * other networking protocols the InputStream may need
         * to be passed to the readXxxWireFormat methods. This is
         * actually purer. However, in the case of smb we know the
         * wordCount and byteCount. And since every subclass of
         * ServerMessageBlock would have to perform the same read
         * operation on the input stream, we might as will pull that
         * common functionality into the superclass and read wordCount
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 38.9K bytes
    - Click Count (0)
  9. docs/en/docs/async.md

    So, during that time, the computer can go and do some other work, while "slow-file" 📝 finishes.
    
    Then the computer / program 🤖 will come back every time it has a chance because it's waiting again, or whenever it 🤖 finished all the work it had at that point. And it 🤖 will see if any of the tasks it was waiting for have already finished, doing whatever it had to do.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:56:21 GMT 2025
    - 24K bytes
    - Click Count (0)
  10. cmd/metacache-set.go

    	// used when o.Versioned is false
    	if !o.Versioned {
    		resolver.requestedVersions = 1
    	}
    	var limit int
    	if o.Limit > 0 && o.StopDiskAtLimit {
    		// Over-read by 4 + 1 for every 16 in limit to give some space for resolver,
    		// allow for truncating the list and know if we have more results.
    		limit = o.Limit + 4 + (o.Limit / 16)
    	}
    	ctxDone := ctx.Done()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.7K bytes
    - Click Count (0)
Back to Top