Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions docs/examples/timer_management/create_timer.py
Original file line number Diff line number Diff line change
@@ -1,14 +1,10 @@
#!/usr/bin/env python

import argparse
import datetime

import globus_sdk
from globus_sdk.experimental.globus_app import UserApp

# Tutorial Client ID - <replace this with your own client>
NATIVE_CLIENT_ID = "61338d24-54d5-408f-a10d-66c06b59f6d2"
USER_APP = UserApp("manage-timers-example", client_id=NATIVE_CLIENT_ID)


def main():
Expand All @@ -31,8 +27,12 @@ def main():
)
args = parser.parse_args()

client = globus_sdk.TimersClient(app=USER_APP)
with globus_sdk.UserApp("manage-timers-example", client_id=NATIVE_CLIENT_ID) as app:
with globus_sdk.TimersClient(app=app) as client:
create_timer(client, args)


def create_timer(client: globus_sdk.TimersClient, args: argparse.Namespace) -> None:
body = globus_sdk.TransferData(
source_endpoint=args.SOURCE_COLLECTION,
destination_endpoint=args.DESTINATION_COLLECTION,
Expand Down
18 changes: 12 additions & 6 deletions docs/examples/timer_management/create_timer_data_access.py
Original file line number Diff line number Diff line change
@@ -1,14 +1,10 @@
#!/usr/bin/env python

import argparse
import datetime

import globus_sdk
from globus_sdk.experimental.globus_app import UserApp

# Tutorial Client ID - <replace this with your own client>
NATIVE_CLIENT_ID = "61338d24-54d5-408f-a10d-66c06b59f6d2"
USER_APP = UserApp("manage-timers-example", client_id=NATIVE_CLIENT_ID)


def uses_data_access(transfer_client, collection_id):
Expand Down Expand Up @@ -40,9 +36,19 @@ def main():
)
args = parser.parse_args()

timers_client = globus_sdk.TimersClient(app=USER_APP)
transfer_client = globus_sdk.TransferClient(app=USER_APP)
with globus_sdk.UserApp("manage-timers-example", client_id=NATIVE_CLIENT_ID) as app:
with (
globus_sdk.TimersClient(app=app) as timers_client,
globus_sdk.TransferClient(app=app) as transfer_client,
):
create_timer(timers_client, transfer_client, args)


def create_timer(
timers_client: globus_sdk.TimersClient,
transfer_client: globus_sdk.TransferClient,
args: argparse.Namespace,
) -> None:
# check if the source or destination use 'data_access' scopes
# if so, register these requirements with the app
if uses_data_access(transfer_client, args.SOURCE_COLLECTION):
Expand Down
12 changes: 4 additions & 8 deletions docs/examples/timer_management/delete_timer.py
Original file line number Diff line number Diff line change
@@ -1,24 +1,20 @@
#!/usr/bin/env python

import argparse

import globus_sdk
from globus_sdk.experimental.globus_app import UserApp

# Tutorial Client ID - <replace this with your own client>
NATIVE_CLIENT_ID = "61338d24-54d5-408f-a10d-66c06b59f6d2"
USER_APP = UserApp("manage-timers-example", client_id=NATIVE_CLIENT_ID)


def main():
parser = argparse.ArgumentParser()
parser.add_argument("TIMER_ID")
args = parser.parse_args()

client = globus_sdk.TimersClient(app=USER_APP)

client.delete_job(args.TIMER_ID)
print("Finished deleting timer.")
with globus_sdk.UserApp("manage-timers-example", client_id=NATIVE_CLIENT_ID) as app:
with globus_sdk.TimersClient(app=app) as client:
client.delete_job(args.TIMER_ID)
print("Finished deleting timer.")


if __name__ == "__main__":
Expand Down
10 changes: 5 additions & 5 deletions docs/examples/timer_management/list_timers.py
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
#!/usr/bin/env python

import globus_sdk
from globus_sdk.experimental.globus_app import UserApp

# Tutorial Client ID - <replace this with your own client>
NATIVE_CLIENT_ID = "61338d24-54d5-408f-a10d-66c06b59f6d2"
USER_APP = UserApp("manage-timers-example", client_id=NATIVE_CLIENT_ID)


def main():
client = globus_sdk.TimersClient(app=USER_APP)
with globus_sdk.UserApp("manage-timers-example", client_id=NATIVE_CLIENT_ID) as app:
with globus_sdk.TimersClient(app=app) as client:
list_timers(client)


def list_timers(client: globus_sdk.TimersClient) -> None:
first = True
for record in client.list_jobs(query_params={"filter_active": True})["jobs"]:
if not first:
Expand Down
Loading