Mirrors/ArchiveBox
2
0
Fork 0
mirror of https://github.com/ArchiveBox/ArchiveBox synced 2024-11-22 04:03:06 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix API and CLU calls

Browse source
This commit is contained in:
Nick Sweeting 2024-11-18 02:25:49 -08:00
parent f65c2b40f8
commit 1e3ce67834
No known key found for this signature in database
2 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
archivebox/api/v1_actors.py
View file

@ -42,9 +42,7 @@ class ActorSchema(Schema):
model: str
statemachine: str
STATE_FIELD_NAME: str
# ACTIVE_STATE: str
FINAL_STATES: list[str]
ACTIVE_STATE: str
EVENT_NAME: str
CLAIM_ORDER: list[str]
CLAIM_FROM_TOP_N: int
@ -67,9 +65,9 @@ class ActorSchema(Schema):
def resolve_name(obj) -> str:
return str(obj)
# @staticmethod
# def resolve_ACTIVE_STATE(obj) -> str:
# return str(obj.ACTIVE_STATE)
@staticmethod
def resolve_ACTIVE_STATE(obj) -> str:
return str(obj.ACTIVE_STATE)
@staticmethod
def resolve_FINAL_STATES(obj) -> list[str]:

9
archivebox/cli/archivebox_add.py
View file

@ -64,8 +64,11 @@ def add(urls: str | list[str],
sources_file.write_text(urls if isinstance(urls, str) else '\n'.join(urls))
# 2. create a new Seed pointing to the sources/2024-11-05__23-59-59__cli_add.txt
cmd = ' '.join(sys.argv)
seed = Seed.from_file(sources_file, label=f'{USER}@{HOSTNAME} $ {cmd}', parser=parser, tag=tag, created_by=created_by_id, config={
cli_args = [*sys.argv]
if cli_args[0].lower().endswith('archivebox'):
cli_args[0] = 'archivebox' # full path to archivebox bin to just archivebox e.g. /Volumes/NVME/Users/squash/archivebox/.venv/bin/archivebox -> archivebox
cmd_str = ' '.join(cli_args)
seed = Seed.from_file(sources_file, label=f'{USER}@{HOSTNAME} $ {cmd_str}', parser=parser, tag=tag, created_by=created_by_id, config={
'ONLY_NEW': not update,
'INDEX_ONLY': index_only,
'OVERWRITE': overwrite,
@ -80,7 +83,7 @@ def add(urls: str | list[str],
# from crawls.actors import CrawlActor
# from core.actors import SnapshotActor, ArchiveResultActor
orchestrator = Orchestrator(exit_on_idle=True)
orchestrator = Orchestrator(exit_on_idle=True, max_concurrent_actors=2)
orchestrator.start()
# 5. return the list of new Snapshots created