snsd0805/gpu-provider
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: snsd0805:master
Branches Tags
snsd0805:master
snsd0805:scatter_image
snsd0805:listen-event
snsd0805:docker-manage
snsd0805:socket
..
compare: snsd0805:scatter_image
Branches Tags
snsd0805:master
snsd0805:scatter_image
snsd0805:listen-event
snsd0805:docker-manage
snsd0805:socket

No commits in common. "master" and "scatter_image" have entirely different histories.
master ... scatter_im

3 changed files with 6 additions and 14 deletions
Show Stats Expand all files Collapse all files

2
src/Scheduler.abi
View File

File diff suppressed because one or more lines are too long

13
src/node_manager.py
View File

@ -85,6 +85,7 @@ class NodeManager():
print(f"And we have load your wallet private key {WALLET_KEY} (address={self.wallet.address})") print(f"And we have load your wallet private key {WALLET_KEY} (address={self.wallet.address})")
print() print()
if self.w3.is_connected(): if self.w3.is_connected():
'''
print("[INFO] Connected Successfully.") print("[INFO] Connected Successfully.")
print() print()
@ -114,23 +115,19 @@ class NodeManager():
train_image = next_task['args']['trainImage'] train_image = next_task['args']['trainImage']
print("\n[INFO] You Receive a new task:") print("\n[INFO] You Receive a new task:")
print(f" - Task Index: {task_index}")
print(f" - Download Image: {data_image}") print(f" - Download Image: {data_image}")
print(f" - Training Image: {train_image}") print(f" - Training Image: {train_image}")
'''
# data_image = "snsd0805/cifar100-dataset:v1" data_image = "snsd0805/cifar100-dataset:v1"
# train_image = "snsd0805/cifar100-train:v3" train_image = "snsd0805/cifar100-train:v3"
# Start Downloading # Start Downloading
self.cluster_communication_module.scatter_container(data_image, train=False) # self.cluster_communication_module.scatter_container(data_image, train=False)
# start training # start training
self.cluster_communication_module.scatter_container(train_image, train=True) self.cluster_communication_module.scatter_container(train_image, train=True)
print("Update the task's status...")
self.scheduler.update_status(self.wallet, task_index, 4)
print("Finished.")
else: else:
print("[ERROR] Connected Failed.") print("[ERROR] Connected Failed.")

5
src/scheduler.py
View File

@ -55,9 +55,4 @@ class Scheduler():
if event['args']['provider'] == address: if event['args']['provider'] == address:
return event return event
def update_status(self, account, task_index, new_status):
function = self.contract.functions.updateStatus(task_index, new_status)
return self.signed_and_send_transaction(account, function)