hydro-project / cloudburst

A stateful serverless platform
Apache License 2.0
237 stars 54 forks source link

Questions about codes in cloudburst/server/scheduler/policy/default_policy.py #56

Closed cosmobiosis closed 4 years ago

cosmobiosis commented 4 years ago

Hi there, hope everyone is doing ok during this hard time of pandemic. Wish you all the best. So, I was following the steps from tutorial and running the codes in client interface of CloudburstConnection, Then I got this attribute errors. It shows that a list object is trying to call discard(), which is a function from python set. So it seems that in cloudburst/server/scheduler/policy/default_policy.py, self.function_locations[function_name] should be a set of executors, but somehow during the runtime it turned to a list. So, I was wondering whether this could be a problem?

local_cloud.register_dag('dag', ['square'], []) (True, 0) Traceback (most recent call last): File "cloudburst/server/scheduler/server.py", line 350, in sched_conf['policy']) File "cloudburst/server/scheduler/server.py", line 231, in scheduler policy.process_status(status) File "/Users/cosmo/Desktop/Files/research/cloudburst/cloudburst/server/scheduler/policy/default_policy.py", line 377, in process_status self.function_locations[function_name].discard(key) AttributeError: 'list' object has no attribute 'discard'