Commit b2890424 authored by Gao, Shang's avatar Gao, Shang
Browse files

finished crossbow globus methods

parent 89bb427e

crossbow/crossbowBase.pyc

deleted100644 → 0
−7.86 KiB

File deleted.

View file

crossbow/crossbowGlobus.py

+9 −9
Original line number Diff line number Diff line
@@ -97,7 +97,7 @@ class crossbowGlobus(crossbowBase): 
        #execute transfer

        tdata = globus_sdk.TransferData(self.transfer, source_endpoint, self.cadesdtn,

                                    label="Crossbow Transfer", sync_level="checksum")

        tdata.add_item(source_path,'/data/cades-crossbow/'+package+'/'+filename)

        tdata.add_item(resource_path,'/data/cades-crossbow/'+package+'/'+filename)

        transfer_result = self.transfer.submit_transfer(tdata)

        print("task_id =", transfer_result["task_id"])
@@ -106,7 +106,7 @@ class crossbowGlobus(crossbowBase): 
                package_id=package,url=url,name=filename,description=description,

                format=format,size=size)

                

        return transfer_result

        return transfer_result["task_id"]



    def download_resource(self,package,resource,dest_endpoint=olcfatlas,

                          dest_path='/~/'):
@@ -183,14 +183,14 @@ class crossbowGlobus(crossbowBase): 
            id of task to check

        '''

        r = self.transfer.get_task(task_id)

        print ("Label:", r["label"])

        print ("Status:", r["status"])

        print ("Transfer: {} -> {}".format(r["source_endpoint_display_name"],

                                           r["destination_endpoint_display_name"]))

        print "Label:", r["label"]

        print "Status:", r["status"]

        print "Transfer: %s -> %s" % (r["source_endpoint_display_name"],

                                      r["destination_endpoint_display_name"])

        if r.data["status"] == "SUCCEEDED":

            print ("Bytes transferred:", r["bytes_transferred"])

            print ("Files transferred:", r["files_transferred"])

            print ("Transfer rate:", r["effective_bytes_per_second"], "bps")

            print "Bytes transferred:", r["bytes_transferred"]

            print "Files transferred:", r["files_transferred"]

            print "Transfer rate:", r["effective_bytes_per_second"], "bps"



#add model api later

#add scheduling api later (for both filters and models)