Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 1,140 for rsync (0.1 sec)

  1. docs_src/async_tests/test_main.py

    import pytest
    from httpx import ASGITransport, AsyncClient
    
    from .main import app
    
    
    @pytest.mark.anyio
    async def test_root():
        async with AsyncClient(
            transport=ASGITransport(app=app), base_url="http://test"
        ) as ac:
            response = await ac.get("/")
        assert response.status_code == 200
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Aug 30 16:00:41 UTC 2024
    - 360 bytes
    - Viewed (0)
  2. docs_src/bigger_applications/app/dependencies.py

    from fastapi import Header, HTTPException
    
    
    async def get_token_header(x_token: str = Header()):
        if x_token != "fake-super-secret-token":
            raise HTTPException(status_code=400, detail="X-Token header invalid")
    
    
    async def get_query_token(token: str):
        if token != "jessica":
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri May 13 23:38:22 UTC 2022
    - 369 bytes
    - Viewed (0)
  3. tensorflow/c/eager/c_api_internal.h

    // TODO(b/154564140): Move this to its own header. This requires splitting
    // c_api_experimental.h
    struct TFE_ContextOptions {
      TF_SessionOptions session_options;
      // true if async execution is enabled.
      bool async = false;
      TFE_ContextDevicePlacementPolicy device_placement_policy{
          TFE_DEVICE_PLACEMENT_SILENT};
      // If true, use TFRT backend
      bool use_tfrt = false;
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Jan 18 19:26:34 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  4. docs_src/bigger_applications/app_an/dependencies.py

    from fastapi import Header, HTTPException
    from typing_extensions import Annotated
    
    
    async def get_token_header(x_token: Annotated[str, Header()]):
        if x_token != "fake-super-secret-token":
            raise HTTPException(status_code=400, detail="X-Token header invalid")
    
    
    async def get_query_token(token: str):
        if token != "jessica":
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 419 bytes
    - Viewed (0)
  5. docs_src/bigger_applications/app_an_py39/dependencies.py

    from typing import Annotated
    
    from fastapi import Header, HTTPException
    
    
    async def get_token_header(x_token: Annotated[str, Header()]):
        if x_token != "fake-super-secret-token":
            raise HTTPException(status_code=400, detail="X-Token header invalid")
    
    
    async def get_query_token(token: str):
        if token != "jessica":
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 409 bytes
    - Viewed (0)
  6. doc/go_mem.html

    			w()
    			<-limit
    		}(w)
    	}
    	select{}
    }
    </pre>
    
    <h3 id="locks">Locks</h3>
    
    <p>
    The <code>sync</code> package implements two lock data types,
    <code>sync.Mutex</code> and <code>sync.RWMutex</code>.
    </p>
    
    <p class="rule">
    For any <code>sync.Mutex</code> or <code>sync.RWMutex</code> variable <code>l</code> and <i>n</i> &lt; <i>m</i>,
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  7. docs_src/request_files/tutorial001_02_py310.py

    from fastapi import FastAPI, File, UploadFile
    
    app = FastAPI()
    
    
    @app.post("/files/")
    async def create_file(file: bytes | None = File(default=None)):
        if not file:
            return {"message": "No file sent"}
        else:
            return {"file_size": len(file)}
    
    
    @app.post("/uploadfile/")
    async def create_upload_file(file: UploadFile | None = None):
        if not file:
            return {"message": "No upload file sent"}
        else:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri May 13 23:38:22 UTC 2022
    - 470 bytes
    - Viewed (0)
  8. internal/cachevalue/cache.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cachevalue
    
    import (
    	"context"
    	"sync"
    	"sync/atomic"
    	"time"
    )
    
    // Opts contains options for the cache.
    type Opts struct {
    	// When set to true, return the last cached value
    	// even if updating the value errors out.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. internal/ioutil/wait_pipe.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package ioutil
    
    import (
    	"io"
    	"sync"
    )
    
    // PipeWriter is similar to io.PipeWriter with wait group
    type PipeWriter struct {
    	*io.PipeWriter
    	once sync.Once
    	done func()
    }
    
    // CloseWithError close with supplied error the writer end.
    func (w *PipeWriter) CloseWithError(err error) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 27 14:55:36 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  10. docs_src/events/tutorial003.py

        return x * 42
    
    
    ml_models = {}
    
    
    @asynccontextmanager
    async def lifespan(app: FastAPI):
        # Load the ML model
        ml_models["answer_to_everything"] = fake_answer_to_everything_ml_model
        yield
        # Clean up the ML models and release the resources
        ml_models.clear()
    
    
    app = FastAPI(lifespan=lifespan)
    
    
    @app.get("/predict")
    async def predict(x: float):
        result = ml_models["answer_to_everything"](x)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Mar 07 15:46:00 UTC 2023
    - 569 bytes
    - Viewed (0)
Back to top