fix: getting storages of last run

[vdusek]

Issues

• Closes Getting storages of last run does not work  #231
• Closes 1.7.0 is a breaking change #240

Testing - abort last run

Sync Actor - works:

from apify_client import ApifyClient

TOKEN = '...'
ACTOR_ID = '...'


def actor_run_abort(apify_client: ApifyClient, actor_id: str) -> None:
    actor_client = apify_client.actor(actor_id)
    actor_client.call(wait_secs=1)
    last_run = actor_client.last_run(status='RUNNING', origin='API')
    aborted_info = last_run.abort()
    print(f'aborted_info: {aborted_info}')


if __name__ == '__main__':
    apify_client = ApifyClient(TOKEN)
    actor_run_abort(apify_client, ACTOR_ID)

Async Actor - works:

import asyncio
from apify_client import ApifyClientAsync

TOKEN = '...'
ACTOR_ID = '...'

async def actor_run_abort_async(apify_client: ApifyClientAsync, actor_id: str) -> None:
    actor_client = apify_client.actor(actor_id)
    await actor_client.call(wait_secs=1)
    last_run = actor_client.last_run(status='RUNNING', origin='API')
    aborted_info = await last_run.abort()
    print(f'aborted_info: {aborted_info}')

if __name__ == '__main__':
    apify_client = ApifyClientAsync(TOKEN)
    asyncio.run(actor_run_abort_async(apify_client, ACTOR_ID))

Sync task - works:

from apify_client import ApifyClient

TOKEN = '...'
TASK_ID = '...'

def task_run_abort(apify_client: ApifyClient, task_id: str) -> None:
    task_client = apify_client.task(task_id)
    task_client.call(wait_secs=1)
    last_run = task_client.last_run(status='RUNNING', origin='API')
    aborted_info = last_run.abort()
    print(f'aborted_info: {aborted_info}')

if __name__ == '__main__':
    apify_client = ApifyClient(TOKEN)
    task_run_abort(apify_client, TASK_ID)

Async task - works:

import asyncio
from apify_client import ApifyClientAsync

TOKEN = '...'
TASK_ID = '...'


async def task_run_abort_async(apify_client: ApifyClientAsync, task_id: str) -> None:
    task_client = apify_client.task(task_id)
    await task_client.call(wait_secs=1)
    last_run = task_client.last_run(status='RUNNING', origin='API')
    aborted_info = await last_run.abort()
    print(f'aborted_info: {aborted_info}')


if __name__ == '__main__':
    apify_client = ApifyClientAsync(TOKEN)
    asyncio.run(task_run_abort_async(apify_client, TASK_ID))

Testing - get storage of last run

Sync Actor - works:

from apify_client import ApifyClient

TOKEN = '...'
ACTOR_ID = '...'


def actor_run_storage(apify_client: ApifyClient, actor_id: str) -> None:
    actor_client = apify_client.actor(actor_id)
    last_run = actor_client.last_run()
    last_run_dataset_client = last_run.dataset()
    info = last_run_dataset_client.get()
    print(f'info: {info}')


if __name__ == '__main__':
    apify_client = ApifyClient(TOKEN)
    task_run_storage(apify_client, ACTOR_ID)

Async Actor - works:

import asyncio

from apify_client import ApifyClientAsync

TOKEN = '...'
ACTOR_ID = '...'


async def actor_run_storage(apify_client: ApifyClientAsync, actor_id: str) -> None:
    actor_client = apify_client.actor(actor_id)
    last_run = actor_client.last_run()
    last_run_dataset_client = last_run.dataset()
    info = await last_run_dataset_client.get()
    print(f'info: {info}')


if __name__ == '__main__':
    apify_client = ApifyClientAsync(TOKEN)
    asyncio.run(task_run_storage(apify_client, ACTOR_ID))

Sync task - works:

from apify_client import ApifyClient

TOKEN = '...'
TASK_ID = '...'


def task_run_storage(apify_client: ApifyClient, task_id: str) -> None:
    task_client = apify_client.task(task_id)
    task_client.call(wait_secs=1)
    last_run = task_client.last_run()
    last_run_dataset_client = last_run.dataset()
    info = last_run_dataset_client.get()
    print(f'info: {info}')


if __name__ == '__main__':
    apify_client = ApifyClient(TOKEN)
    task_run_storage(apify_client, TASK_ID)

Async task - works:

import asyncio

from apify_client import ApifyClientAsync

TOKEN = '...'
TASK_ID = '...'


async def task_run_storage(apify_client: ApifyClientAsync, task_id: str) -> None:
    task_client = apify_client.task(task_id)
    await task_client.call(wait_secs=1)
    last_run = task_client.last_run()
    last_run_dataset_client = last_run.dataset()
    info = await last_run_dataset_client.get()
    print(f'info: {info}')


if __name__ == '__main__':
    apify_client = ApifyClientAsync(TOKEN)
    asyncio.run(task_run_storage(apify_client, TASK_ID))

[github-actions]

⚠️ Pull Request Tookit has failed!

None of the pull request and linked issue has estimate

[github-actions]

⚠️ Pull Request Tookit has failed!

None of the pull request and linked issue has estimate

[barjin]

lgtm as this just reverts the known-good implementation from 1.6.4 👍🏽 cheers!