I now implemented a "dirty" way to check for the cache job, because I still don't know where to check for the job with the job_id provided by the publish function .
If someone else might find this thread, this is how I check if the cache job is still running:
- publish the scene layer
- get the scene layer uri
- check in loop if propertie "lastUpdate" has a value different then "-999999"
- if so, cache generation is finished
- publish the next scene layer
This script only checks on one layer of the published data ("/layers/0"), if your data would have more then one scene layer, you need to edit this.
I still would appreciate it, if someone would point me to the "right" way on checking the cache status using the job_id.
def get_token(server_url, username, password):
url = f"{server_url}/admin/generateToken"
data = {
"username": username,
"password": password,
"client": "requestip",
"f": "json"
}
r = requests.post(url, data=data, verify=False)
r.raise_for_status()
return r.json()["token"]
def get_layer_last_update(layer_url, token):
params = {"f": "json", "token": token}
r = requests.get(layer_url, params=params, verify=False)
r.raise_for_status()
layer_info = r.json()
return layer_info.get("serviceUpdateTimeStamp", {}).get("lastUpdate", -999999)
#...
#generate aprx an stuff to publish data
#...
res = arcpy.sharing.Publish(scene_draft)
print(r"item_url: " + res["web_scene_layer"]["item_url"])
print(r"rest_url: " + res["web_scene_layer"]["rest_url"])
print(r"cache_job_id: " + res["web_scene_layer"]["cache_job_id"])
timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
print(f"[{timestamp}] Finish Publishing {bu}")
layer_url = res["web_scene_layer"]["rest_url"] + r"/layers/0"
token = get_token(server_url, username, password)
token_expires = datetime.now() + timedelta(minutes=30)
while True:
try:
#refresh token after 30 minutes
if datetime.now() >= token_expires:
token = get_token(server_url, username, password)
token_expires = datetime.now() + timedelta(minutes=30)
last_update = get_layer_last_update(layer_url, token)
timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
status_text = f"[{timestamp}] 🔍 cache generation still running (lastUpdate = {last_update})"
print(status_text.ljust(100), end="\r") # Zeile überschreiben
if last_update != -999999:
print(f"\n✅ cache generation finished (lastUpdate = {last_update})")
break
except Exception as e:
print(f"❗ error fetching lastUpdate: {e}")
break
time.sleep(60)
