Skip to content

Commit

Permalink
remove web route
Browse files Browse the repository at this point in the history
  • Loading branch information
surcyf123 committed Mar 9, 2024
1 parent 87dd2c9 commit 501f701
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion state.json

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion template/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@


# version must stay on line 22
__version__ = "3.2.1"
__version__ = "3.2.2"
version_split = __version__.split(".")
__spec_version__ = (
(1000 * int(version_split[0]))
Expand Down
6 changes: 3 additions & 3 deletions validators/validator.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ def get_config() -> bt.config:
parser = argparse.ArgumentParser()
parser.add_argument("--netuid", type=int, default=18)
parser.add_argument('--wandb_off', action='store_false', dest='wandb_on')
parser.add_argument('--http_port', type=int, default=8000)
parser.add_argument('--http_port', type=int, default=8100)
parser.set_defaults(wandb_on=True)
bt.subtensor.add_args(parser)
bt.logging.add_args(parser)
Expand Down Expand Up @@ -155,10 +155,10 @@ def __init__(self, *a, **kw):


validator_app = ValidatorApplication()
validator_app.add_routes([web.post('/text-validator/', process_text_validator)])
# validator_app.add_routes([web.post('/text-validator/', process_text_validator)])


def main(run_aio_app=False, test=False) -> None:
def main(run_aio_app=True, test=False) -> None:
config = get_config()
wallet, subtensor, dendrite, my_uid = initialize_components(config)
validator_config = {
Expand Down
2 changes: 1 addition & 1 deletion validators/weight_setter.py
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ def __init__(self, loop: asyncio.AbstractEventLoop, dendrite, subtensor, config,
self.organic_scoring_tasks = set()

self.thread_executor = concurrent.futures.ThreadPoolExecutor(thread_name_prefix='asyncio')
self.loop.create_task(self.consume_organic_scoring())
# self.loop.create_task(self.consume_organic_scoring())
self.loop.create_task(self.perform_synthetic_scoring_and_update_weights())

async def run_sync_in_async(self, fn):
Expand Down

0 comments on commit 501f701

Please sign in to comment.