Mike,

I tried the same thing (Except for DbImage) on my windows box. I didn't face any problem. It must be related to your environment. We need to put some logs in SourceJob to find more details

When you create a queue, it should trigger async for both create and query. Is the create is going through fine?

#Sources
:sources:
  BlobImage:
    :poll_interval: 30
    :queue: image_queue

:development:
  :licensefile: settings/license.key
  :redis: 127.0.0.1:6379
  :syncserver: http://localhost:9292
  :api_token: rhoconnect_api_token

Image model is as below

require 'active_record'
require 'fileutils'

class BlobImage < Rhoconnect::Model::Base
  def initialize(source)
    super(source)
  end

  def login
    # TODO: Login to your data source here if necessary
  end

  def query(params=nil)
    # TODO: Query your backend data source and assign the records
    # to a nested hash structure called @result. For example:
    # @result = {
    #   "1"=>{"name"=>"Acme", "industry"=>"Electronics"},
    #   "2"=>{"name"=>"Best", "industry"=>"Software"}
    # }
#   raise Rhoconnect::Model::Exception.new("Please provide some code to read records from the backend data source")
  puts "inside query"
  return {}
  end

  def create(create_hash)
    # TODO: Create a new record in your backend data source
#   raise "Please provide some code to create a single record in the backend data source using the create_hash"
  puts "create_hash: #{create_hash}"

    name = create_hash["image_uri"]
   
    # filename we saved in application.rb#store_blob method
    basename = create_hash["filename"]

  puts "basename is #{basename}"

    #DbImage.create(create_hash)

    return create_hash["filename"]
  end

  def update(update_hash)
    # TODO: Update an existing record in your backend data source
    raise "Please provide some code to update a single record in the backend data source using the update_hash"
  end

  def delete(delete_hash)
    # TODO: write some code here if applicable
    # be sure to have a hash key and value for "object"
    # for now, we'll say that its OK to not have a delete operation
    # raise "Please provide some code to delete a single object in the backend application using the object_id"
  end

  def logoff
    # TODO: Logout from the data source if necessary
  end

  def store_blob(object,field_name,blob)
    # TODO: Handle post requests for blobs here.
    # make sure you store the blob object somewhere permanently
    # raise "Please provide some code to handle blobs if you are using them."
  puts "fieldname: #{field_name}"
    puts "store_blob: #{blob}"
    root_path = "/"
    file_name = blob[:filename]
    puts "filename: #{blob[:filename]}"

    # Save the file to the path
    puts "class: #{blob[:tempfile].class}"
    from = blob[:tempfile].path
    to = "#{blob[:filename].to_s}"

    puts "Copying #{from} => #{to}"

    # Create folder path if it doesn't exist
    #if (!File.directory?(to))
    # FileUtils.mkdir_p(File.dirname(to))
    #end
   
    #Copy file
    FileUtils.cp(from, to)
   
    #Change file permissions so that it is readable by everyone
    File.chmod(0666, to)
   
    #Change group and owner to PlanetAdmin
    File.chown(500, 500, to)
   
   
    object['filename'] = blob[:filename].to_s

  end
end

Thanks
Krishna