Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 346 for Celery (0.16 sec)

  1. docs/en/docs/deployment/docker.md

        Using the cache in this step will **save** you a lot of **time** when building the image again and again during development, instead of **downloading and installing** all the dependencies **every time**.
    
    5. Copy the `./app` directory inside the `/code` directory.
    
        As this has all the code which is what **changes most frequently** the Docker **cache** won't be used for this or any **following steps** easily.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  2. 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.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 28 23:33:37 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  3. 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()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    	curr fileReader // Reader for current file entry
    	blk  block      // Buffer to use as temporary local storage
    
    	// err is a persistent error.
    	// It is only the responsibility of every exported method of Reader to
    	// ensure that this error is sticky.
    	err error
    }
    
    type fileReader interface {
    	io.Reader
    	fileState
    
    	WriteTo(io.Writer) (int64, error)
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/networking/v1/generated.proto

      //   done on a path element by element basis. A path element refers is the
      //   list of labels in the path split by the '/' separator. A request is a
      //   match for path p if every p is an element-wise prefix of p of the
      //   request path. Note that if the last element of the path is a substring
      //   of the last element in request path, it is not a match (e.g. /foo/bar
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    )
    
    // Temp files created in default Tmp dir
    var globalTestTmpDir = os.TempDir()
    
    // reseed - returns a new seed every time the function is called.
    func reseed() uint32 {
    	return uint32(time.Now().UnixNano() + int64(os.Getpid()))
    }
    
    // nextSuffix - provides a new unique suffix every time the function is called.
    func nextSuffix() string {
    	randmu.Lock()
    	r := randN
    	// Initial seed required, generate one.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/MapMakerInternalMap.java

          if ((readCount.incrementAndGet() & DRAIN_THRESHOLD) == 0) {
            runCleanup();
          }
        }
    
        /**
         * Performs routine cleanup prior to executing a write. This should be called every time a write
         * thread acquires the segment lock, immediately after acquiring the lock.
         */
        @GuardedBy("this")
        void preWriteCleanup() {
          runLockedCleanup();
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  8. doc/go_mem.html

    sending an item acquires the semaphore, and receiving an item releases
    the semaphore.
    This is a common idiom for limiting concurrency.
    </p>
    
    <p>
    This program starts a goroutine for every entry in the work list, but the
    goroutines coordinate using the <code>limit</code> channel to ensure
    that at most three are running work functions at a time.
    </p>
    
    <pre>
    var limit = make(chan int, 3)
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    	// Start the disk monitoring and connect routine.
    	if !globalIsTesting {
    		go s.monitorAndConnectEndpoints(ctx, defaultMonitorConnectEndpointInterval)
    	}
    
    	return s, nil
    }
    
    // cleanup ".trash/" folder every 5m minutes with sufficient sleep cycles, between each
    // deletes a dynamic sleeper is used with a factor of 10 ratio with max delay between
    // deletes to be 2 seconds.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  10. cmd/admin-handlers-users.go

    					// clean import.
    					err := globalIAMSys.DeleteServiceAccount(ctx, svcAcctReq.AccessKey, true)
    					if err != nil {
    						delErr := fmt.Errorf("failed to delete existing service account (%s) before importing it: %w", svcAcctReq.AccessKey, err)
    						writeErrorResponseJSON(ctx, w, importError(ctx, delErr, allSvcAcctsFile, user), r.URL)
    						return
    					}
    				}
    				opts := newServiceAccountOpts{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
Back to top