Support timeouts for FalClient::subscribe
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Idoneità per principianti
- 58/100
Direzione di ricerca
Inizia da FalClient::subscribe e dai tipi SubscribeOptions e QueueSubscribeOptions, quindi esamina QueueClientImpl.kt intorno alla chiamata a future.get(). Determina come il timeout debba essere esposto e passato come start_timeout e come debba limitare l’attesa. Il lavoro è completato quando entrambi i tipi di opzioni di sottoscrizione supportano il timeout e l’attesa della queue lo rispetta.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
Would it be possible to support timeouts for the FalClient::subscribe method? Currently, neither SubscribeOptions nor QueueSubscribeOptions provide the ability to supply a timeout.
Ideally a timeout configuration would mean that the client would send it as the start_timeout:
start_timeout:
Server-side deadline in seconds, sent as the X-Fal-Request-Timeout header. This sets an absolute wall-clock deadline, computed once when the request is submitted. The server checks this deadline before processing begins. If the deadline has passed, the server returns a 504 without processing the request.... as documented at https://fal.ai/docs/documentation/model-apis/inference/queue
Furthermore, it should also use the timeout to do a bounded wait on this future in QueueClientImpl.kt
public class QueueClientImpl implements QueueClient {
...
public Completed subscribeToStatus(@Nonnull String endpointId, @Nonnull QueueSubscribeptions options) {
...
final var listener = new EventSourceListener {
...
try {
return future.get(); // -> future.get(start_timeout + some buffer?);
} catch (Exception ex) {
throw new FalException(ex.getMessage(), ex, options.getRequestId());
}
}
}
}
Happy to contribute if this makes sense.
- Lingua principale
- Java
- Stelle
- 15
- Fork
- 2
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Preparare l'ambiente
Questo progetto non fornisce container di sviluppo, Dockerfile né guida per i contributori, quindi l'ambiente è a tuo carico: parti dal suo README e consulta la nostra guida al primo contributo per i passaggi generali.
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di fal-ai/fal-java
-
Difficoltà 3/5 1-2 giorni Idoneità per principianti 48/100
-
Difficoltà 5/5 Più di una settimana Idoneità per principianti 20/100
-
Kotlin Multiplatform supportAperta
Difficoltà 5/5 Più di una settimana Idoneità per principianti 25/100
Tutte le issue di fal-ai/fal-java
Issue simili
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 68/100
Netcracker/qubership-integration-platform#1046 ·
I maintainer di solito rispondono entro 2 giorni
-
`check_java_version()` fails when Java path contains spaces (Windows / Git Bash, `C:\Program Files`)Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 68/100
-
Fix Math.ceilDiv wrong result for exact positive divisionsForse già presa @pamod-madubashana l’ha presa oggi. Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 88/100
scala-native/scala-native#5094 ·
I maintainer di solito rispondono entro 1 giorno
-
[Bug] AI unread message badge counts a batch of new bubbles as one messageForse già presa Una pull request collegata a questa issue è aperta o già unita. Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 74/100
apache/rocketmq-dashboard#5784 ·
I maintainer di solito rispondono entro 3 giorni
-
[i18n] 安装实例完成后的成功提示未正确本地化Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 62/100
PCL-Community/PCL-CE#3658 ·
I maintainer di solito rispondono entro 1 giorno