Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 391 for ctx_ (0.05 sec)

  1. tests/test_tutorial/test_path_params/test_tutorial005.py

                        "input": "foo",
                        "ctx": {"expected": "'alexnet', 'resnet' or 'lenet'"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"enum_values": ["alexnet", "resnet", "lenet"]},
                        "loc": ["path", "model_name"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Sep 28 04:14:40 UTC 2023
    - 5K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. cmd/endpoint-ellipses.go

    			return fmt.Errorf("all args must have ellipses for pool expansion (%w) args: %s", errInvalidArgument, args)
    		}
    		setArgs, err = GetAllSets(setDriveCount, arg)
    		if err != nil {
    			return err
    		}
    		ctxt.Layout.pools = append(ctxt.Layout.pools, poolDisksLayout{cmdline: arg, layout: setArgs})
    	}
    	return
    }
    
    // CreateServerEndpoints - validates and creates new endpoints from input args, supports
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/config-current_test.go

    package cmd
    
    import (
    	"context"
    	"os"
    	"testing"
    
    	"github.com/minio/minio/internal/config"
    )
    
    func TestServerConfig(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    
    	if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 2K bytes
    - Viewed (0)
  8. cmd/erasure-decode.go

    				}
    			}
    		} else if err != nil {
    			return err
    		}
    
    		if err = e.DecodeDataAndParityBlocks(ctx, bufs); err != nil {
    			return err
    		}
    
    		w := multiWriter{
    			writers:     writers,
    			writeQuorum: 1,
    			errs:        make([]error, len(writers)),
    		}
    
    		if err = w.Write(ctx, bufs); err != nil {
    			return err
    		}
    	}
    
    	return derr
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top