- Sort Score
- Num 10 results
- Language All
Results 261 - 270 of 311 for Celery (0.06 seconds)
-
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.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Sep 20 12:58:04 GMT 2025 - 29.5K bytes - Click Count (1) -
guava/src/com/google/common/collect/AbstractMapBasedMultimap.java
* AbstractMapBasedMultimap} calls {@link #createCollection()} to create the collection of values * for that key. The subclass should not call {@link #createCollection()} directly, and a new * instance should be created every time the method is called. * * <p>For example, the subclass could pass a {@link java.util.TreeMap} during construction, and * {@link #createCollection()} could return a {@link java.util.TreeSet}, in which case theCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Nov 17 22:50:48 GMT 2025 - 48.4K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.17.md
- Kube-apiserver now reloads serving certificates from disk every minute to allow rotation without restarting the server process ([#84200](https://github.com/kubernetes/kubernetes/pull/84200), [@jackkleeman](https://github.com/jackkleeman))
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Thu Jan 28 10:44:33 GMT 2021 - 346.2K bytes - Click Count (1) -
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{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 90.6K bytes - Click Count (0) -
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) -
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)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Aug 05 15:41:37 GMT 2025 - 26.6K bytes - Click Count (0) -
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.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 37K bytes - Click Count (1) -
android/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(); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 89.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
assertThat(c.eventSequence).isEmpty() assertThat(d.takeEvent()).isInstanceOf<CallStart>() assertThat(d.eventSequence).isEmpty() } /** Reflectively call every event function to confirm it is correctly forwarded. */ @Test fun aggregateEventListenerIsComplete() { val sampleValues = sampleValuesMap() val solo = EventRecorder(enforceOrder = false)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 70.5K bytes - Click Count (0) -
src/cmd/asm/internal/asm/parse.go
return } // General address (with a few exceptions) looks like // $sym±offset(SB)(reg)(index*scale) // Exceptions are: // // R1 // offset // $offset // Every piece is optional, so we scan left to right and what // we discover tells us where we are. // Prefix: $. var prefix rune switch tok := p.peek(); tok { case '$', '*': prefix = rune(tok) p.next()
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Nov 12 03:59:40 GMT 2025 - 37.3K bytes - Click Count (0)