Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 453 for ctx_ (0.03 sec)

  1. tests/test_regex_deprecated_params.py

                        "input": "nonregexquery",
                        "ctx": {"pattern": "^fixedquery$"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"pattern": "^fixedquery$"},
                        "loc": ["query", "q"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. tests/transaction_test.go

    		}
    	})
    }
    
    func TestCancelTransaction(t *testing.T) {
    	ctx := context.Background()
    	ctx, cancelFunc := context.WithCancel(ctx)
    	cancelFunc()
    
    	user := *GetUser("cancel_transaction", Config{})
    	DB.Create(&user)
    
    	err := DB.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
    		var result User
    		tx.First(&result, user.ID)
    		return nil
    	})
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  3. cmd/encryption-v1.go

    	}
    }
    
    func newEncryptMetadata(ctx context.Context, kind crypto.Type, keyID string, key []byte, bucket, object string, metadata map[string]string, cryptoCtx kms.Context) (crypto.ObjectKey, error) {
    	var sealedKey crypto.SealedKey
    	switch kind {
    	case crypto.S3:
    		if GlobalKMS == nil {
    			return crypto.ObjectKey{}, errKMSNotConfigured
    		}
    		key, err := GlobalKMS.GenerateKey(ctx, &kms.GenerateKeyRequest{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  4. src/test/java/jcifs/tests/BaseCIFSTest.java

            @Override
            public Configuration getConfig () {
                return this.cfg;
            }
        }
    
    
        protected static CIFSContext withConfig ( CIFSContext ctx, final DelegatingConfiguration cfg ) {
            return new CIFSConfigContextWrapper(ctx, cfg);
        }
    
    
        @Before
        public void setUp () throws Exception {
            Properties props = new Properties();
            props.putAll(this.properties);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 8.1K bytes
    - Viewed (0)
  5. internal/lsync/lrwmutex.go

    }
    
    // GetLock tries to get a write lock on lm before the timeout occurs.
    func (lm *LRWMutex) GetLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) {
    	const isWriteLock = true
    	return lm.lockLoop(ctx, id, source, timeout, isWriteLock)
    }
    
    // RLock holds a read lock on lm.
    //
    // If one or more read lock are already in use, it will grant another lock.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  6. istioctl/pkg/precheck/precheck_test.go

    	}
    
    	for _, c := range cases {
    		t.Run(fmt.Sprintf("revision=%s, version=%s", c.revision, c.version), func(t *testing.T) {
    			ctx := cli.NewFakeContext(&cli.NewFakeContextOption{
    				IstioNamespace: "istio-system",
    			})
    			output, err := checkFromVersion(ctx, c.revision, c.version)
    
    			assert.Equal(t, output, c.expectedOutput)
    
    			if c.expectedError != nil {
    				assert.Error(t, err)
    			} else {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 09 12:01:22 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. cmd/lock-rest-client_test.go

    	}
    	endpointLocal, err := NewEndpoint("http://localhost:9012")
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	endpointLocal.IsLocal = true
    
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	err = initGlobalLockGrid(ctx, []PoolEndpoints{{Endpoints: Endpoints{endpoint, endpointLocal}}})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	lkClient := newlockRESTClient(endpoint)
    	if lkClient.IsOnline() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 2K bytes
    - Viewed (0)
  8. cmd/metrics-v3-system-memory.go

    )
    
    // loadMemoryMetrics - `MetricsLoaderFn` for node memory metrics.
    func loadMemoryMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	memMetrics, err := c.memoryMetrics.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return err
    	}
    
    	m.Set(memTotal, float64(memMetrics.Total))
    	m.Set(memUsed, float64(memMetrics.Used))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 17 05:10:25 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  9. internal/grid/debug.go

    	}
    	dialer := &net.Dialer{
    		Timeout: 5 * time.Second,
    	}
    	var res TestGrid
    	res.Hosts = hosts
    	ready := make(chan struct{})
    	ctx, cancel := context.WithCancel(context.Background())
    	res.cancel = cancel
    	for i, host := range hosts {
    		manager, err := NewManager(ctx, ManagerOptions{
    			Dialer: ConnectWS(dialer.DialContext,
    				dummyNewToken,
    				nil),
    			Local:        host,
    			Hosts:        hosts,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. tensorflow/c/c_api_experimental.cc

        return;
      }
      status->status = tensorflow::unwrap(ctx)->EnableCollectiveOps(server_def);
    }
    
    TF_CAPI_EXPORT extern void TFE_AbortCollectiveOps(TFE_Context* ctx,
                                                      TF_Status* status) {
      tensorflow::EagerContext* context =
          tensorflow::ContextFromInterface(tensorflow::unwrap(ctx));
      auto collective_executor_handle = context->GetCollectiveExecutorHandle();
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 29.5K bytes
    - Viewed (0)
Back to top