Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 143 for walkers (0.13 sec)

  1. .idea/scopes/Gradle_public_API.xml

    </component>...
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Thu Jul 18 15:08:47 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  2. cmd/notification.go

    type NotificationGroup struct {
    	workers    *workers.Workers
    	errs       []NotificationPeerErr
    	retryCount int
    }
    
    // WithNPeers returns a new NotificationGroup with length of errs slice upto nerrs,
    // upon Wait() errors are returned collected from all tasks.
    func WithNPeers(nerrs int) *NotificationGroup {
    	if nerrs <= 0 {
    		nerrs = 1
    	}
    	wk, _ := workers.New(nerrs)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. .teamcity/subprojects.json

        "path": "platforms/enterprise/enterprise-plugin-performance",
        "unitTests": false,
        "functionalTests": false,
        "crossVersionTests": false
      },
      {
        "name": "enterprise-workers",
        "path": "platforms/enterprise/enterprise-workers",
        "unitTests": false,
        "functionalTests": false,
        "crossVersionTests": false
      },
      {
        "name": "execution",
        "path": "platforms/core-execution/execution",
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Wed Oct 23 22:33:41 UTC 2024
    - 34.3K bytes
    - Viewed (0)
  4. tensorflow/c/eager/immediate_execution_distributed_manager.h

          int64_t init_timeout_in_ms, int retries,
          bool clear_existing_contexts = false) = 0;
    
      // Initializes context for the local worker and no contexts will be created
      // for remote workers. Currently this only works for resetting context.
      // TODO(b/289445025): Consider removing this when we find a proper fix.
      virtual absl::Status InitializeLocalOnlyContext(const ServerDef& server_def,
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportAggregationWorkAction.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package gradlebuild.incubation.action
    
    import org.gradle.workers.WorkAction
    
    
    abstract class IncubatingApiReportAggregationWorkAction : WorkAction<IncubatingApiReportAggregationParameter> {
        override fun execute() {
            val byCategory = mutableMapOf<String, ReportNameToProblems>()
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Mon Jan 18 06:55:55 UTC 2021
    - 3.4K bytes
    - Viewed (0)
  6. cmd/batch-expire_test.go

          purge:
              # retainVersions: 0 # (default) delete all versions of the object. This option is the fastest.
              # retainVersions: 5 # keep the latest 5 versions of the object including delete markers.
    
      notify:
        endpoint: https://notify.endpoint # notification endpoint to receive job completion status
        token: Bearer xxxxx # optional authentication token for the notification endpoint
      
      retry:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. docs/en/docs/deployment/concepts.md

    Here are some possible combinations and strategies:
    
    * **Uvicorn** with `--workers`
        * One Uvicorn **process manager** would listen on the **IP** and **port**, and it would start **multiple Uvicorn worker processes**.
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  8. internal/s3select/csv/reader.go

    	current      [][]string       // current block of results to be returned
    	recordsRead  int              // number of records read in current slice
    	input        chan *queueItem  // input for workers
    	queue        chan *queueItem  // output from workers in order
    	err          error            // global error state, only touched by Reader.Read
    	bufferPool   sync.Pool        // pool of []byte objects for input
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  10. internal/config/api/api.go

    	if err != nil {
    		return cfg, err
    	}
    	if replicationMaxWorkers <= 0 || replicationMaxWorkers > 500 {
    		return cfg, config.ErrInvalidReplicationWorkersValue(nil).Msg("Number of replication workers should be between 1 and 500")
    	}
    	cfg.ReplicationMaxWorkers = replicationMaxWorkers
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 11.5K bytes
    - Viewed (1)
Back to top