ジョブのPython wheel タスク
Python wheel としてパッケージ化されたコードをデプロイするには、Python wheel タスクタイプを使用します。
要件
- Python wheelファイルは、コンピュート構成と互換性のある場所またはリポジトリにアップロードする必要があります。
setup.pyファイルで定義されている名前とエントリポイントを知っている必要があります。setup.pyの例については、「LakeFlowジョブでPython wheelファイルを使用する」を参照してください。
Python wheel タスクを構成します
ジョブ UI は、その他の設定に基づいてオプションを動的に表示します。
Jobs UIの タスク タブからPython wheelタスクを以下の手順で追加します。
-
[ タスクを追加 ] をクリックします。 -
「タスク名」 フィールドに名前を入力します。
-
タイプ ドロップダウンメニューで、
Python wheelを選択します。 -
パッケージ名 フィールドに、
name変数に割り当てられた値をsetup.pyに入力します。 -
エントリポイント フィールドに、ホイール内のロジックを実行する関数を入力します。この関数は、
setup.pyのentry_pointsディクショナリのキーとして定義する必要があります。 -
コンピュート を使用して、ホイールのロジックをサポートするクラスターを選択または構成します。
-
Serverlessコンピュートを使用する場合は、「環境とライブラリ」フィールドを使用して、新しい環境を選択、編集、または追加します。サーバレス環境を構成するを参照してください。 -
他のすべてのコンピュート設定については、「**依存ライブラリ**」の下の
「**追加**」をクリックします。「**依存ライブラリの追加**」ダイアログが表示されます。- 既存のPython wheelを選択するか、新しいPython wheelファイルをアップロードできます。
- wheel ファイルは、コンピュート構成でサポートされている場所に保存する必要があります。Python ライブラリ サポートを参照してください。
- 各 ライブラリ ソース には、wheel を選択またはアップロードするための異なるフローがあります。ライブラリのインストールを参照してください。
-
(オプション) パラメーター を構成します。 位置指定引数 または キーワード引数 のいずれかを使用できます。タスク パラメーターの設定を参照してください。
-
(オプション) 再試行、実行期間、ストリーミングバックログのしきい値、または通知を設定するには、高度なタスク設定を参照してください。
-
タスクの保存 をクリックします。
このタスクを編集、クローン、無効化、または削除するには、「Lakeflowジョブでタスクを構成および編集する」を参照してください。