Dask Yenileme Numarası Nedir?
Dask yenileme numarası, Dask’ın bir işin durumunu takip etmek için kullandığı benzersiz bir tanımlayıcıdır. Her iş, başlatıldığında bir yenileme numarası alır ve bu numara, işin tamamlanana kadar veya iptal edilene kadar geçerli kalır. Yenileme numarası, işin durumunu kontrol etmek, işin ilerlemesini izlemek ve işleri iptal etmek için kullanılabilir.
Dask Yenileme Numarasını Nasıl Bulurum?
Dask yenileme numarası, dask.distributed.Client.submit() işlevi kullanılarak bir iş başlatıldığında döndürülür. Yenileme numarası, Future nesnesinin key özelliğinde saklanır. Örneğin:
“`python
import dask.distributed
client = dask.distributed.Client()
future = client.submit(lambda x: x + 1, 10)
print(future.key)
“`
Yukarıdaki örnekte, future.key özelliği, işin yenileme numarasını içerir.
Dask Yenileme Numarasını Nasıl Kullanırım?
Dask yenileme numarası, işin durumunu kontrol etmek, işin ilerlemesini izlemek ve işleri iptal etmek için kullanılabilir.
İşin Durumunu Kontrol Etme
İşin durumunu kontrol etmek için, dask.distributed.Client.status() işlevi kullanılabilir. Bu işlev, yenileme numarası verilen bir işin durumunu döndürür. Örneğin:
“`python
import dask.distributed
client = dask.distributed.Client()
future = client.submit(lambda x: x + 1, 10)
status = client.status(future.key)
print(status)
“`
Yukarıdaki örnekte, client.status() işlevi, işin durumunu döndürür. İşin durumu, 'pending', 'running', 'finished', 'failed' veya 'cancelled' olabilir.
İşin İlerlemesini İzleme
İşin ilerlemesini izlemek için, dask.distributed.Client.progress() işlevi kullanılabilir. Bu işlev, yenileme numarası verilen bir işin ilerlemesini döndürür. Örneğin:
“`python
import dask.distributed
client = dask.distributed.Client()
future = client.submit(lambda x: x + 1, 10)
progress = client.progress(future.key)
print(progress)
“`
Yukarıdaki örnekte, client.progress() işlevi, işin ilerlemesini döndürür. İşin ilerlemesi, 0.0 ile 1.0 arasında bir değerdir.
İşleri İptal Etme
Bir işi iptal etmek için, dask.distributed.Client.cancel() işlevi kullanılabilir. Bu işlev, yenileme numarası verilen bir işi iptal eder. Örneğin:
“`python
import dask.distributed
client = dask.distributed.Client()
future = client.submit(lambda x: x + 1, 10)
client.cancel(future.key)
“`
Yukarıdaki örnekte, client.cancel() işlevi, işi iptal eder. İptal edilen iş, 'cancelled' durumuna geçer.
Sonuç
Dask yenileme numarası, Dask’ın bir işin durumunu takip etmek için kullandığı benzersiz bir tanımlayıcıdır. Yenileme numarası, işin durumunu kontrol etmek, işin ilerlemesini izlemek ve işleri iptal etmek için kullanılabilir.