MCPcopy Index your code
hub / github.com/feast-dev/feast / connect

Method connect

sdk/python/feast/feature_server.py:732–734  ·  view source on GitHub ↗
(self, websocket: WebSocket)

Source from the content-addressed store, hash-verified

730 self.active_connections: List[WebSocket] = []
731
732 async def connect(self, websocket: WebSocket):
733 await websocket.accept()
734 self.active_connections.append(websocket)
735
736 def disconnect(self, websocket: WebSocket):
737 self.active_connections.remove(websocket)

Callers 15

websocket_endpointFunction · 0.80
_get_connFunction · 0.80
_get_conn_asyncFunction · 0.80
__enter__Method · 0.80
_initialize_connFunction · 0.80
_get_sessionMethod · 0.80
_get_connMethod · 0.80
_init_connMethod · 0.80
compute_monitoring_metricsMethod · 0.80
get_monitoring_max_timestampMethod · 0.80
_get_cursorMethod · 0.80
get_ibis_connectionFunction · 0.80

Calls

no outgoing calls

Tested by 11

add_pg_read_only_userFunction · 0.64
test_pull_latest_from_ray_sql_source_filters_and_deduplicatesFunction · 0.64
test_stored_writesMethod · 0.64
test_stored_writes_with_explodeMethod · 0.64
setup_duckdbMethod · 0.64
setup_pgMethod · 0.64
test_numeric_mean_matches_across_backendsMethod · 0.64
test_categorical_unique_count_matchesMethod · 0.64
test_null_rate_matches_across_backendsMethod · 0.64
test_sqlite_vec_importFunction · 0.64
test_sqlite_hybrid_searchFunction · 0.64