Send Data to specific branch using specklepy

dvalent · 2 August 2022 17:44

Hi community!
hopefully is a quick one but I cant figure this out.
I’ve programmatically created Streams and branches using specklepy without a hitch
now, every package I send using transport is always sent to the main stream.
I’ve tried using the Stream Wrapper to create a transport directed to a branch url but im getting an error:

sqlite3.ProgrammingError: SQLite objects created in a thread can only be used in that same thread. The object was created in thread id 4000 and this is thread id 12892

how can I select a specific branch to send data to?

keep up the good work!

gokermu · 3 August 2022 08:27

Hi @dvalent ,
Welcome to the community! Feel free to Introduce yourself to the community if you want to!

I found this on our Examples repo and i think it does what you ask for. Can you give it a try?

github.com

specklesystems/speckle-examples/blob/096cc9852fe612a5b831c57e4f855603f599465d/python/speckle-py-starter/01_send_receive.py#L45-L57


      
          # Send the points using a specific transport
          newHash = operations.send(base=received_base, transports=[transport])
          
          
# you can now create a commit on your stream with this object
          commit_id = client.commit.create(
              stream_id=streamId,
              branch_name=branchName,
              object_id=newHash,
              message="Automatic commit created the python starter example",
              source_application="PyStarter"
          )
          
          
print("Successfully created commit with id: ", commit_id)

AlanRynne · 3 August 2022 09:01

Just to clarify a bit on @gokermu’s answer:

the ServerTransport is kind of a “dumb” concept that is only in charge of:

Sending an object to a stream and returning it’s ID
Receiving an object from a stream by it’s ID

The transport does not send to a specific branch, all uploaded objects belong to a Stream, but are not part of any branch unless you create a commit after uploading it. Which is when you’re able to specify what branch it should belong to.

Notice that on the example Bilal shared, when creating a Transport, you only need to specify the Stream it points to.

github.com

specklesystems/speckle-examples/blob/096cc9852fe612a5b831c57e4f855603f599465d/python/speckle-py-starter/01_send_receive.py#L33


      
          
          
# Authenticate using the account token
          client.authenticate(token=account.token)
          # Get the main branch with it's latest commit reference
          branch = client.branch.get(streamId, "main", 1)
          # Get the id of the object referenced in the commit
          objHash = branch.commits.items[0].referencedObject
          
          

          
# Create the server transport for the specified stream.
          transport = ServerTransport(client=client, stream_id=streamId)
          
          
# Receive the object
          received_base = operations.receive(obj_id=objHash, remote_transport=transport)
          
          

          
# The received object, process it as you wish.
          print("Received object:", received_base)
          
          
# TODO: Perform some operation on the received data

I will admit that the error you’re getting seems rather unhelpful Could you share with us a snippet of your code so we can see what’s going on, and either prevent it from happening, or display a more meaningful error instead?

Thanks for reporting this!

dvalent · 3 August 2022 09:13

Thanks @gokermu , this was it! a simple branch_name argument! all working now

dvalent · 3 August 2022 09:24

I realized the error was more verbose after the post - I will edit it
Essentially when I looked into the transport object the account keys were empty - even though I authorized with a token previously - the error I was getting it was a credentials error in the end. I installed the speckle Manager and the error just went away.

I will investigate further - Thanks!