2016-08-04 3 views
2

dask를 사용하여 한 태스크에서 다른 태스크로 검색 할 수있는 변수가있는 방법이 있습니까? 나는 내가 작업자를 잠근 다음 다른 작업을 실행할 때 같은 작업자에서 검색 할 수있는 변수를 의미합니다.Dask 작업자 영구 변수

답변

1

직원 자체는 단지 파이썬 프로세스이므로 globals()으로 트릭을 수행 할 수 있습니다.

그러나 값을 내보내고 작업간에 전달하는 것이 더 깔끔합니다. Dask는 기능을 다시 실행하여 다른 시스템에서 실행할 수있는 권한을 보유하므로 전역 상태 또는 작업자 별 상태에 따라 쉽게 문제를 일으킬 수 있습니다.

+0

대답은 Thx이지만 전역 트릭은 작동하지 않는 것처럼 보입니다. 나는이 코드를 노동자들에게 실행 시키려고했다 :'i = 0 def 엔진 (cmd) : global i print ('i : % d'% (i)) i = i + 1'. 그러나 카운터는 0으로 유지됩니다. – Bertrand

+0

네, 답변을 위해 – MRocklin

+0

Thx를 사용하지 않는 것이 좋습니다. 그렇게 다르게 처리하려고합니다. – Bertrand