skygpu
/
skynet
mirror of https://github.com/skygpu/skynet.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Switch to gpu.scd in all relevant segments

pull/28/head
Guillermo Rodriguez 2024-11-26 21:40:13 -03:00 committed by zoltan
parent 7f62bf0044
commit 3eab407c00
9 changed files with 33 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
skynet/cli.py
View File

@ -141,7 +141,7 @@ def enqueue(
})
res = await cleos.a_push_action(
'telos.gpu',
'gpu.scd',
'enqueue',
{
'user': Name(account),
@ -176,7 +176,7 @@ def clean(
trio.run(
partial(
cleos.a_push_action,
'telos.gpu',
'gpu.scd',
'clean',
{},
account, key, permission=permission
@ -191,9 +191,9 @@ def queue():
resp = requests.post(
f'{node_url}/v1/chain/get_table_rows',
json={
'code': 'telos.gpu',
'code': 'gpu.scd',
'table': 'queue',
'scope': 'telos.gpu',
'scope': 'gpu.scd',
'json': True
}
)
@ -208,7 +208,7 @@ def status(request_id: int):
resp = requests.post(
f'{node_url}/v1/chain/get_table_rows',
json={
'code': 'telos.gpu',
'code': 'gpu.scd',
'table': 'status',
'scope': request_id,
'json': True
@ -232,7 +232,7 @@ def dequeue(request_id: int):
res = trio.run(
partial(
cleos.a_push_action,
'telos.gpu',
'gpu.scd',
'dequeue',
{
'user': Name(account),
@ -267,7 +267,7 @@ def config(
res = trio.run(
partial(
cleos.a_push_action,
'telos.gpu',
'gpu.scd',
'config',
{
'token_contract': token_contract,
@ -296,13 +296,13 @@ def deposit(quantity: str):
res = trio.run(
partial(
cleos.a_push_action,
'telos.gpu',
'gpu.scd',
'transfer',
{
'sender': Name(account),
'recipient': Name('telos.gpu'),
'recipient': Name('gpu.scd'),
'amount': asset_from_str(quantity),
'memo': f'{account} transferred {quantity} to telos.gpu'
'memo': f'{account} transferred {quantity} to gpu.scd'
},
account, key, permission=permission
)

18
skynet/dgpu/network.py
View File

@ -72,7 +72,7 @@ class SkynetGPUConnector:
return await failable(
partial(
self.cleos.aget_table,
'telos.gpu', 'telos.gpu', 'queue',
'gpu.scd', 'gpu.scd', 'queue',
index_position=2,
key_type='i64',
lower_bound=int(time.time()) - 3600
@ -83,14 +83,14 @@ class SkynetGPUConnector:
return await failable(
partial(
self.cleos.aget_table,
'telos.gpu', request_id, 'status'), ret_fail=[])
'gpu.scd', request_id, 'status'), ret_fail=[])
async def get_global_config(self):
logging.info('get_global_config')
rows = await failable(
partial(
self.cleos.aget_table,
'telos.gpu', 'telos.gpu', 'config'))
'gpu.scd', 'gpu.scd', 'config'))
if rows:
return rows[0]
@ -102,7 +102,7 @@ class SkynetGPUConnector:
rows = await failable(
partial(
self.cleos.aget_table,
'telos.gpu', 'telos.gpu', 'users',
'gpu.scd', 'gpu.scd', 'users',
index_position=1,
key_type='name',
lower_bound=self.account,
@ -149,7 +149,7 @@ class SkynetGPUConnector:
return await failable(
partial(
self.cleos.a_push_action,
'telos.gpu',
'gpu.scd',
'workbegin',
{
'worker': self.account,
@ -166,7 +166,7 @@ class SkynetGPUConnector:
return await failable(
partial(
self.cleos.a_push_action,
'telos.gpu',
'gpu.scd',
'workcancel',
{
'worker': self.account,
@ -189,7 +189,7 @@ class SkynetGPUConnector:
await failable(
partial(
self.cleos.a_push_action,
'telos.gpu',
'gpu.scd',
'withdraw',
{
'user': self.account,
@ -205,7 +205,7 @@ class SkynetGPUConnector:
return await failable(
partial(
self.cleos.aget_table,
'telos.gpu', 'telos.gpu', 'results',
'gpu.scd', 'gpu.scd', 'results',
index_position=4,
key_type='name',
lower_bound=self.account,
@ -224,7 +224,7 @@ class SkynetGPUConnector:
return await failable(
partial(
self.cleos.a_push_action,
'telos.gpu',
'gpu.scd',
'submit',
{
'worker': self.account,

4
skynet/frontend/discord/__init__.py
View File

@ -155,7 +155,7 @@ class SkynetDiscordFrontend:
reward = '20.0000 GPU'
res = await self.cleos.a_push_action(
'telos.gpu',
'gpu.scd',
'enqueue',
{
'user': Name(self.account),
@ -202,7 +202,7 @@ class SkynetDiscordFrontend:
try:
submits = await self.hyperion.aget_actions(
account=self.account,
filter='telos.gpu:submit',
filter='gpu.scd:submit',
sort='desc',
after=request_time
)

2
skynet/frontend/discord/handlers.py
View File

@ -309,7 +309,7 @@ def create_handler_context(frontend: 'SkynetDiscordFrontend'):
# async def queue(message):
# an_hour_ago = datetime.now() - timedelta(hours=1)
# queue = await cleos.aget_table(
# 'telos.gpu', 'telos.gpu', 'queue',
# 'gpu.scd', 'gpu.scd', 'queue',
# index_position=2,
# key_type='i64',
# sort='desc',

4
skynet/frontend/discord/utils.py
View File

@ -112,12 +112,12 @@ def generate_reply_caption(
async def get_global_config(cleos):
return (await cleos.aget_table(
'telos.gpu', 'telos.gpu', 'config'))[0]
'gpu.scd', 'gpu.scd', 'config'))[0]
async def get_user_nonce(cleos, user: str):
return (await cleos.aget_table(
'telos.gpu', 'telos.gpu', 'users',
'gpu.scd', 'gpu.scd', 'users',
index_position=1,
key_type='name',
lower_bound=user,

4
skynet/frontend/telegram/__init__.py
View File

@ -143,7 +143,7 @@ class SkynetTelegramFrontend:
reward = '20.0000 GPU'
res = await self.cleos.a_push_action(
'telos.gpu',
'gpu.scd',
'enqueue',
{
'user': Name(self.account),
@ -193,7 +193,7 @@ class SkynetTelegramFrontend:
try:
submits = await self.hyperion.aget_actions(
account=self.account,
filter='telos.gpu:submit',
filter='gpu.scd:submit',
sort='desc',
after=request_time
)

2
skynet/frontend/telegram/handlers.py
View File

@ -47,7 +47,7 @@ def create_handler_context(frontend: 'SkynetTelegramFrontend'):
async def queue(message):
an_hour_ago = datetime.now() - timedelta(hours=1)
queue = await cleos.aget_table(
'telos.gpu', 'telos.gpu', 'queue',
'gpu.scd', 'gpu.scd', 'queue',
index_position=2,
key_type='i64',
sort='desc',

4
skynet/frontend/telegram/utils.py
View File

@ -95,11 +95,11 @@ def generate_reply_caption(
async def get_global_config(cleos):
return (await cleos.aget_table(
'telos.gpu', 'telos.gpu', 'config'))[0]
'gpu.scd', 'gpu.scd', 'config'))[0]
async def get_user_nonce(cleos, user: str):
return (await cleos.aget_table(
'telos.gpu', 'telos.gpu', 'users',
'gpu.scd', 'gpu.scd', 'users',
index_position=1,
key_type='name',
lower_bound=user,

8
skynet/ipfs/pinner.py
View File

@ -44,8 +44,8 @@ class SkynetPinner:
async def capture_enqueues(self, after: datetime):
enqueues = await self.hyperion.aget_actions(
account='telos.gpu',
filter='telos.gpu:enqueue',
account='gpu.scd',
filter='gpu.scd:enqueue',
sort='desc',
after=after.isoformat(),
limit=1000
@ -63,8 +63,8 @@ class SkynetPinner:
async def capture_submits(self, after: datetime):
submits = await self.hyperion.aget_actions(
account='telos.gpu',
filter='telos.gpu:submit',
account='gpu.scd',
filter='gpu.scd:submit',
sort='desc',
after=after.isoformat(),
limit=1000